From 65ca8169455def5a0cac8933f1be48cfad5291f3 Mon Sep 17 00:00:00 2001 From: Thanh Le Date: Fri, 1 Dec 2023 22:21:16 +0100 Subject: [PATCH] Fix cleantime instant, it == now minus 3 sconds --- app/src/main/scala/Jobs.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/app/src/main/scala/Jobs.scala b/app/src/main/scala/Jobs.scala index ef1c5e1..9e1604b 100644 --- a/app/src/main/scala/Jobs.scala +++ b/app/src/main/scala/Jobs.scala @@ -35,4 +35,5 @@ object WorkCleaningJob: def run(): IO[Unit] = Logger[IO].info("Start cleaning job") *> IO.sleep(5.seconds) *> - (IO.realTimeInstant.flatMap(executor.clean) *> IO.sleep(3.seconds)).foreverM + (IO.realTimeInstant.flatMap(now => executor.clean(now.minusSeconds(3))) *> + IO.sleep(3.seconds)).foreverM