From d974a63d62771540fac6189950445ce3685aa7fa Mon Sep 17 00:00:00 2001 From: colmsnowplow Date: Fri, 10 Nov 2023 10:48:20 +0000 Subject: [PATCH] Comment cleanup --- .../snowplow/sinks/kinesis/KinesisSink.scala | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/modules/kinesis/src/main/scala/com/snowplowanalytics/snowplow/sinks/kinesis/KinesisSink.scala b/modules/kinesis/src/main/scala/com/snowplowanalytics/snowplow/sinks/kinesis/KinesisSink.scala index 7c68ddf..146ba90 100644 --- a/modules/kinesis/src/main/scala/com/snowplowanalytics/snowplow/sinks/kinesis/KinesisSink.scala +++ b/modules/kinesis/src/main/scala/com/snowplowanalytics/snowplow/sinks/kinesis/KinesisSink.scala @@ -154,10 +154,11 @@ object KinesisSink { /** * The build method creates a TryBatchResult, which: * - * Returns an empty list and false for hadNonThrottleErrors if everything was successful Returns - * the list of failed requests and true for hadNonThrottleErrors if we encountered any errors - * that weren't throttles Returns the list of failed requests and false for hadNonThrottleErrors - * if we encountered only throttling + * - Returns an empty list and false for hadNonThrottleErrors if everything was successful + * - Returns the list of failed requests and true for hadNonThrottleErrors if we encountered + * any errors that weren't throttles + * - Returns the list of failed requests and false for hadNonThrottleErrors if we encountered + * only throttling */ def build(records: List[PutRecordsRequestEntry], prr: PutRecordsResponse): TryBatchResult = if (prr.failedRecordCount().toInt =!= 0) @@ -190,7 +191,7 @@ object KinesisSink { private def tryWriteToKinesis[F[_]: Sync]( streamName: String, kinesis: KinesisClient, - records: List[PutRecordsRequestEntry] // , + records: List[PutRecordsRequestEntry] ): F[Vector[PutRecordsRequestEntry]] = Logger[F].debug(s"Writing ${records.size} records to ${streamName}") *> Sync[F]