diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index 52b2448a..9511440a 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -88,9 +88,8 @@ class Zookeeper extends Process { $redis = Snowflake::app()->getRedis(); - $startTime = time(); + $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)time()); - $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); $redis->zRem(Producer::CRONTAB_KEY, ...$range); return [$range, $redis];