Method: Burstflow::Manager#job_performed!

Defined in:
lib/burstflow/manager.rb

#job_performed!(job, result) ⇒ Object

Mark job finished or suspended depends on result or output



83
84
85
86
87
88
89
90
91
 
# File 'lib/burstflow/manager.rb', line 83

def job_performed!(job, result)
  if result == Burstflow::Job::SUSPEND || job.output == Burstflow::Job::SUSPEND
    suspend_job!(job)
  else
    finish_job!(job)
  end
rescue => e
  raise Burstflow::Workflow::InternalError.new(workflow, e.message)
end