diff --git a/batch/batches/KJobCloserWorker.class.php b/batch/batches/KJobCloserWorker.class.php index a91a52d76bd..fde6e4afac3 100644 --- a/batch/batches/KJobCloserWorker.class.php +++ b/batch/batches/KJobCloserWorker.class.php @@ -19,7 +19,7 @@ public function run($jobs = null) if(! count($jobs) > 0) { KalturaLog::info("Queue size: 0 sent to scheduler"); - $this->saveSchedulerQueue(static::getType()); + $this->saveSchedulerQueue(static::getType(), 0); return null; } diff --git a/batch/batches/KJobHandlerWorker.class.php b/batch/batches/KJobHandlerWorker.class.php index b1f5ad6d73a..4c22e8e69e0 100644 --- a/batch/batches/KJobHandlerWorker.class.php +++ b/batch/batches/KJobHandlerWorker.class.php @@ -90,7 +90,7 @@ public function run($jobs = null) if(! count($jobs) > 0) { KalturaLog::info("Queue size: 0 sent to scheduler"); - $this->saveSchedulerQueue(static::getType()); + $this->saveSchedulerQueue(static::getType(), 0); return null; } diff --git a/batch/batches/Mailer/KAsyncMailer.class.php b/batch/batches/Mailer/KAsyncMailer.class.php index af1fe7fac97..5c37f594009 100644 --- a/batch/batches/Mailer/KAsyncMailer.class.php +++ b/batch/batches/Mailer/KAsyncMailer.class.php @@ -62,7 +62,7 @@ public function run($jobs = null) if(!count($jobs) > 0) { KalturaLog::info("Queue size: 0 sent to scheduler"); - $this->saveSchedulerQueue(self::getType()); + $this->saveSchedulerQueue(self::getType(), 0); return; } diff --git a/batch/batches/Notifier/KAsyncNotifier.class.php b/batch/batches/Notifier/KAsyncNotifier.class.php index 9756884646d..6864275ae28 100644 --- a/batch/batches/Notifier/KAsyncNotifier.class.php +++ b/batch/batches/Notifier/KAsyncNotifier.class.php @@ -52,7 +52,7 @@ public function run($jobs = null) if(! count($jobs)) { KalturaLog::info("Queue size: 0 sent to scheduler"); - $this->saveSchedulerQueue(self::getType()); + $this->saveSchedulerQueue(self::getType(), 0); return; }