9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
# File 'lib/gush/worker.rb', line 9
def perform(workflow_id, job_id, configuration_json)
configure_client(configuration_json)
workflow = client.find_workflow(workflow_id)
job = workflow.find_job(job_id)
start = Time.now
report(workflow, job, :started, start)
job.logger = workflow.build_logger_for_job(job, job_id)
job.jid = jid
failed = false
error = nil
mark_as_started(workflow, job)
begin
job.before_work
job.work
job.after_work
rescue Exception => e
failed = true
error = e
end
unless failed
report(workflow, job, :finished, start)
mark_as_finished(workflow, job)
continue_workflow(workflow)
else
log_exception(job.logger, error)
mark_as_failed(workflow, job)
report(workflow, job, :failed, start, error.message)
end
end
|