TEMP-- monix bug fix

filodb · Dec 6, 2021 · c98ee1e · c98ee1e
1 parent 418eeda
commit c98ee1e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/coordinator/src/main/scala/filodb.coordinator/TenantIngestionMetering.scala b/coordinator/src/main/scala/filodb.coordinator/TenantIngestionMetering.scala
@@ -44,8 +44,10 @@ case class TenantIngestionMetering(settings: FilodbSettings,
 
   def schedulePeriodicPublishJob() : Unit = {
     scheduler.scheduleWithFixedDelay(
-      SCHED_INIT_DELAY,
-      SCHED_DELAY)(() => queryAndSchedulePublish())
+      SCHED_INIT_DELAY.toSeconds,
+      SCHED_DELAY.toSeconds,
+      TimeUnit.SECONDS,
+      () => queryAndSchedulePublish())
   }
 
   /**