Increase logging around starting PubSub Subscriber

snowplow-incubator · May 6, 2024 · d9c69ff · d9c69ff
1 parent 19a1f06
commit d9c69ff
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...es/pubsub/src/main/scala/com/snowplowanalytics/snowplow/sources/pubsub/PubsubSource.scala b/...es/pubsub/src/main/scala/com/snowplowanalytics/snowplow/sources/pubsub/PubsubSource.scala
@@ -222,7 +222,9 @@ object PubsubSource {
                         _ <- fiber.join
                       } yield ()
                     }
+      _ <- Resource.eval(Logger[F].info("Waiting for PubSub Subscriber to be up and running...."))
       _ <- Resource.eval(Sync[F].blocking(apiService.awaitRunning()))
+      _ <- Resource.eval(Logger[F].info("PubSub Subscriber is running"))
     } yield ()
 
   private def drainQueue[F[_]: Async](control: Control): F[Unit] =