diff --git a/app/jobs/storage/materialize_job.rb b/app/jobs/storage/materialize_job.rb index b2e494977..78ecd3746 100644 --- a/app/jobs/storage/materialize_job.rb +++ b/app/jobs/storage/materialize_job.rb @@ -2,6 +2,8 @@ class Storage::MaterializeJob < ApplicationJob queue_as :backend limits_concurrency to: 1, key: ->(owner) { owner } + discard_on ActiveJob::DeserializationError + def perform(owner) owner.materialize_storage end diff --git a/app/jobs/storage/reconcile_job.rb b/app/jobs/storage/reconcile_job.rb index dde6dcb2e..be0c0748c 100644 --- a/app/jobs/storage/reconcile_job.rb +++ b/app/jobs/storage/reconcile_job.rb @@ -1,6 +1,8 @@ class Storage::ReconcileJob < ApplicationJob queue_as :backend + discard_on ActiveJob::DeserializationError + def perform(owner) owner.reconcile_storage end