From bdfc9df0e2edf3392e444fc0b108eb8d09128fab Mon Sep 17 00:00:00 2001
From: Guntis Smaukstelis <gsmaukstelis@evolution.com>
Date: Sun, 14 May 2023 16:08:44 +0300
Subject: [PATCH] Log scheduler started with initial delay

---
 src/main/scala/server/Scheduler.scala | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/main/scala/server/Scheduler.scala b/src/main/scala/server/Scheduler.scala
index ba47354..834b29f 100644
--- a/src/main/scala/server/Scheduler.scala
+++ b/src/main/scala/server/Scheduler.scala
@@ -2,6 +2,7 @@ package server
 
 import cats.effect._
 import cats.effect.unsafe.implicits.global
+import cats.implicits.catsSyntaxApply
 import fetch.{FetchService, FileNameService}
 import fs2.Stream
 
@@ -33,9 +34,11 @@ object Scheduler {
 //  }
 
   def scheduleTask(task: IO[(String, String)]): Stream[IO, (String, String)] = {
-    Stream.eval(durationToNextHalfHour).flatMap { delay =>
-      (Stream.sleep[IO](delay) ++ Stream.awakeEvery[IO](1.hour)).evalMap(_ => task)
-    }
+    Stream.eval(durationToNextHalfHour).flatMap { delay => {
+      Stream.eval(IO.println(s"Scheduler started with delay: ${delay.toMinutes} min")) *>
+      (Stream.sleep[IO](delay) ++ Stream.awakeEvery[IO](1.hour))
+        .evalMap(_ => task)
+    }}
   }
 
   def main(args: Array[String]): Unit = {