diff --git a/System/Crontab/Producer.php b/System/Crontab/Producer.php index fa7b5645..7769d0ad 100644 --- a/System/Crontab/Producer.php +++ b/System/Crontab/Producer.php @@ -16,7 +16,7 @@ use Snowflake\Snowflake; class Producer extends Component { - const CRONTAB_KEY = '_application:system:crontab'; + const CRONTAB_KEY = '_application:{crontab}:system:crontab'; /** diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index 2e585b53..612bb41c 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -118,11 +118,14 @@ class Zookeeper extends Process */ private function loadCarobTask(Redis|\Redis $redis): array { - $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)time()); + $script = <<