From a2c2c6ba039d07139a308ff6843f94adc4f53db3 Mon Sep 17 00:00:00 2001 From: Hamed Kamrava Date: Mon, 20 Mar 2023 14:33:39 +0300 Subject: [PATCH 1/2] fix commands overlapping issue --- src/FairQueueServiceProvider.php | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/FairQueueServiceProvider.php b/src/FairQueueServiceProvider.php index 80fd6bb..736d465 100644 --- a/src/FairQueueServiceProvider.php +++ b/src/FairQueueServiceProvider.php @@ -61,17 +61,17 @@ public function boot(): void if(config('fair-queue.recover_lost_jobs.enabled')) { $age = config('fair-queue.recover_lost_jobs.age', 3600); // recover lost jobs since `$age` seconds ago - $schedule->command(RecoverLostJobs::class, [$age])->hourly(); + $schedule->command(RecoverLostJobs::class, [$age])->hourly()->withoutOverlapping();; } if(config('fair-queue.recover_stuck_jobs.enabled')) { // recover stuck jobs - $schedule->command(RecoverStuckJobs::class)->everyFiveMinutes(); + $schedule->command(RecoverStuckJobs::class)->everyFiveMinutes()->withoutOverlapping();; // remove extra Horizon signals - $schedule->command(RemoveExtraHorizonSignals::class)->everyFiveMinutes(); + $schedule->command(RemoveExtraHorizonSignals::class)->everyFiveMinutes()->withoutOverlapping();; } // refresh stats for dashboard - $schedule->command(RefreshStats::class)->everyMinute(); + $schedule->command(RefreshStats::class)->everyMinute()->withoutOverlapping();; }); } From e758f05e9e6a129a3393758ca1708c6ad710cb53 Mon Sep 17 00:00:00 2001 From: Hamed Kamrava Date: Mon, 20 Mar 2023 14:35:03 +0300 Subject: [PATCH 2/2] cleanup --- src/FairQueueServiceProvider.php | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/FairQueueServiceProvider.php b/src/FairQueueServiceProvider.php index 736d465..3fec8d1 100644 --- a/src/FairQueueServiceProvider.php +++ b/src/FairQueueServiceProvider.php @@ -61,17 +61,17 @@ public function boot(): void if(config('fair-queue.recover_lost_jobs.enabled')) { $age = config('fair-queue.recover_lost_jobs.age', 3600); // recover lost jobs since `$age` seconds ago - $schedule->command(RecoverLostJobs::class, [$age])->hourly()->withoutOverlapping();; + $schedule->command(RecoverLostJobs::class, [$age])->hourly()->withoutOverlapping(); } if(config('fair-queue.recover_stuck_jobs.enabled')) { // recover stuck jobs - $schedule->command(RecoverStuckJobs::class)->everyFiveMinutes()->withoutOverlapping();; + $schedule->command(RecoverStuckJobs::class)->everyFiveMinutes()->withoutOverlapping(); // remove extra Horizon signals - $schedule->command(RemoveExtraHorizonSignals::class)->everyFiveMinutes()->withoutOverlapping();; + $schedule->command(RemoveExtraHorizonSignals::class)->everyFiveMinutes()->withoutOverlapping(); } // refresh stats for dashboard - $schedule->command(RefreshStats::class)->everyMinute()->withoutOverlapping();; + $schedule->command(RefreshStats::class)->everyMinute()->withoutOverlapping(); }); }