diff --git a/app/workers/distribution_worker.rb b/app/workers/distribution_worker.rb index 09374bee293..f423d43ae58 100644 --- a/app/workers/distribution_worker.rb +++ b/app/workers/distribution_worker.rb @@ -5,5 +5,7 @@ class DistributionWorker def perform(status_id) FanOutOnWriteService.new.call(Status.find(status_id)) + rescue ActiveRecord::RecordNotFound + true end end diff --git a/app/workers/pubsubhubbub/distribution_worker.rb b/app/workers/pubsubhubbub/distribution_worker.rb index b0ddc71c1c1..e88d11be0a8 100644 --- a/app/workers/pubsubhubbub/distribution_worker.rb +++ b/app/workers/pubsubhubbub/distribution_worker.rb @@ -14,5 +14,7 @@ class Pubsubhubbub::DistributionWorker Subscription.where(account: account).active.select('id').find_each do |subscription| Pubsubhubbub::DeliveryWorker.perform_async(subscription.id, payload) end + rescue ActiveRecord::RecordNotFound + true end end diff --git a/app/workers/removal_worker.rb b/app/workers/removal_worker.rb index eae27c66fa0..19a660dd3e0 100644 --- a/app/workers/removal_worker.rb +++ b/app/workers/removal_worker.rb @@ -5,5 +5,7 @@ class RemovalWorker def perform(status_id) RemoveStatusService.new.call(Status.find(status_id)) + rescue ActiveRecord::RecordNotFound + true end end