Fixes #15376: Forget to fork backend batch

Normation · Aug 1, 2019 · 36f2580 · 36f2580
1 parent c161e71
commit 36f2580
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...udder/rudder-core/src/main/scala/com/normation/rudder/batch/PurgeDeletedInventories.scala b/...udder/rudder-core/src/main/scala/com/normation/rudder/batch/PurgeDeletedInventories.scala
@@ -79,7 +79,7 @@ class PurgeDeletedInventories(
           ScheduledJobLoggerPure.error(error.fullMsg)
       })
       import zio.duration.Duration.{fromScala => zduration}
-      ZioRuntime.unsafeRun(prog.delay(zduration(10.minutes)).repeat(Schedule.spaced(zduration(updateInterval))).provide(ZioRuntime.Environment))
+      ZioRuntime.unsafeRun(prog.delay(zduration(10.minutes)).repeat(Schedule.spaced(zduration(updateInterval))).provide(ZioRuntime.Environment).fork)
     }
   }
 }

diff --git a/...er/rudder-core/src/main/scala/com/normation/rudder/batch/PurgeUnreferencedSoftwares.scala b/...er/rudder-core/src/main/scala/com/normation/rudder/batch/PurgeUnreferencedSoftwares.scala
@@ -72,7 +72,7 @@ class PurgeUnreferencedSoftwares(
     }}
 
     import zio.duration.Duration.{fromScala => zduration}
-    ZioRuntime.unsafeRun(prog.delay(zduration(1.hour)).repeat(Schedule.spaced(zduration(updateInterval))).provide(ZioRuntime.Environment))
+    ZioRuntime.unsafeRun(prog.delay(zduration(1.hour)).repeat(Schedule.spaced(zduration(updateInterval))).provide(ZioRuntime.Environment).fork)
   }
 }