diff --git a/lib/ResqueScheduler/Worker.php b/lib/ResqueScheduler/Worker.php index 73e0051..e02b43f 100644 --- a/lib/ResqueScheduler/Worker.php +++ b/lib/ResqueScheduler/Worker.php @@ -55,7 +55,7 @@ public function work($interval = null) */ public function handleDelayedItems($timestamp = null) { - while (($timestamp = ResqueScheduler::nextDelayedTimestamp($timestamp)) !== false) { + while (($timestamp = ResqueScheduler::nextDelayedTimestamp()) !== false) { $this->updateProcLine('Processing Delayed Items'); $this->enqueueDelayedItemsForTimestamp($timestamp); }