Class: Shikibu::Integrations::ActiveJob::ResumeJob

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
lib/shikibu/integrations/active_job.rb

Overview

Job for resuming workflows

Instance Method Summary collapse

Instance Method Details

#perform(instance_id) ⇒ Object 



60
61
62
63
64
65
 
# File 'lib/shikibu/integrations/active_job.rb', line 60

def perform(instance_id)
  Shikibu.app.resume_workflow(instance_id)
rescue LockNotAcquiredError
  # Another worker got it, retry later
  self.class.set(wait: 1.second).perform_later(instance_id)
end