diff --git a/app/Jobs/MovePipeline/CleanupLegacyAccountMovePipeline.php b/app/Jobs/MovePipeline/CleanupLegacyAccountMovePipeline.php index 5e99c95b..cc8a7a04 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 a5f687fa..d087745b 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. */