Class: SagaForge::Dashboard::BulkRecoveryJob

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
app/jobs/saga_forge/dashboard/bulk_recovery_job.rb

Overview

Fans out per-instance retry/resume off the request thread. The "Retry all stalled" / "Resume all suspended" buttons enqueue one of these instead of looping in the controller, so the HTTP request stays fast even when thousands of instances are eligible.

Idempotent like the per-instance operator methods it calls: both retry_stalled! and resume! are status-scoped no-ops when there's nothing eligible on a given instance, so a duplicate enqueue (or a race with a per-instance retry) is harmless.

Instance Method Summary collapse

Instance Method Details

#perform(saga_class, mode) ⇒ Object 



13
14
15
16
17
 
# File 'app/jobs/saga_forge/dashboard/bulk_recovery_job.rb', line 13

def perform(saga_class, mode)
  scope = SagaForge::State.for_saga(saga_class)
  scope = (mode == "resume") ? scope.suspended : scope.stalled
  scope.find_each { |state| (mode == "resume") ? state.resume! : state.retry_stalled! }
end