Class: ApprovalEngine::TimeoutSweepJob

Inherits:
ApplicationJob
  • Object
show all
Defined in:
app/jobs/approval_engine/timeout_sweep_job.rb

Overview

Periodic safety net that fires the timeout signal for every step whose deadline has passed. Schedule it with whatever recurring mechanism you already run (solid_queue recurring tasks, sidekiq-cron, the ‘whenever` gem, a Kubernetes CronJob hitting a rake task, …):

ApprovalEngine::TimeoutSweepJob.perform_later              # all tenants
ApprovalEngine::TimeoutSweepJob.perform_later(tenant_id: .id)

Idempotent: each step times out at most once, so running it more often only makes timeouts fire sooner — it never double-fires.

Instance Method Summary collapse

Instance Method Details

#perform(tenant_id: nil) ⇒ Object



15
16
17
# File 'app/jobs/approval_engine/timeout_sweep_job.rb', line 15

def perform(tenant_id: nil)
  Step.sweep_timeouts!(tenant_id: tenant_id)
end