Update pubsub/src/main/scala/com.snowplowanalytics.snowplow.collector…

…s.scalastream/sinks/PubSubSink.scala Co-authored-by: Benjamin BENOIST <[email protected]>
snowplow · Aug 21, 2023 · 0a11403 · 0a11403
1 parent e4c182b
commit 0a11403
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...c/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/PubSubSink.scala b/...c/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/PubSubSink.scala
@@ -49,8 +49,8 @@ class PubSubSink[F[_]: Async: Parallel: Logger] private (
 
   private def produceBatch(events: List[Array[Byte]]): F[Unit] =
     events.parTraverse_ { event =>
-      produceSingleEvent(event) *> isHealthyState.set(true)
-    }
+      produceSingleEvent(event)
+    }  *> isHealthyState.set(true)
 
   private def produceSingleEvent(event: Array[Byte]): F[Model.MessageId] =
     producer