From a7efd20bbc26d87ef1546e446cdd8b76094c5fe3 Mon Sep 17 00:00:00 2001 From: Daniel Supernault Date: Sat, 7 Sep 2024 03:40:33 -0600 Subject: [PATCH] Fix MovePipeline jobs --- .../CleanupLegacyAccountMovePipeline.php | 12 +----------- .../UnfollowLegacyAccountMovePipeline.php | 12 +----------- 2 files changed, 2 insertions(+), 22 deletions(-) diff --git a/app/Jobs/MovePipeline/CleanupLegacyAccountMovePipeline.php b/app/Jobs/MovePipeline/CleanupLegacyAccountMovePipeline.php index 5e99c95bd..cc8a7a047 100644 --- a/app/Jobs/MovePipeline/CleanupLegacyAccountMovePipeline.php +++ b/app/Jobs/MovePipeline/CleanupLegacyAccountMovePipeline.php @@ -48,7 +48,7 @@ class CleanupLegacyAccountMovePipeline implements ShouldQueue public function middleware(): array { return [ - new WithoutOverlapping('process-move-cleanup-legacy-followers:'.$this->activity), + new WithoutOverlapping('process-move-cleanup-legacy-followers:'.$this->target), (new ThrottlesExceptions(2, 5 * 60))->backoff(5), ]; } @@ -61,16 +61,6 @@ class CleanupLegacyAccountMovePipeline implements ShouldQueue return now()->addMinutes(15); } - /** - * Get the middleware the job should pass through. - * - * @return array - */ - public function middleware(): array - { - return [new WithoutOverlapping($this->target)]; - } - /** * Execute the job. */ diff --git a/app/Jobs/MovePipeline/UnfollowLegacyAccountMovePipeline.php b/app/Jobs/MovePipeline/UnfollowLegacyAccountMovePipeline.php index a5f687fa0..d087745b2 100644 --- a/app/Jobs/MovePipeline/UnfollowLegacyAccountMovePipeline.php +++ b/app/Jobs/MovePipeline/UnfollowLegacyAccountMovePipeline.php @@ -51,7 +51,7 @@ class UnfollowLegacyAccountMovePipeline implements ShouldQueue public function middleware(): array { return [ - new WithoutOverlapping('process-move-undo-legacy-followers:'.$this->activity), + new WithoutOverlapping('process-move-undo-legacy-followers:'.$this->target), (new ThrottlesExceptions(2, 5 * 60))->backoff(5), ]; } @@ -64,16 +64,6 @@ class UnfollowLegacyAccountMovePipeline implements ShouldQueue return now()->addMinutes(15); } - /** - * Get the middleware the job should pass through. - * - * @return array - */ - public function middleware(): array - { - return [new WithoutOverlapping($this->target)]; - } - /** * Execute the job. */