1 module PipelineInstancesHelper
3 def pipeline_jobs object=nil
5 if object.components[:steps].is_a? Array
6 pipeline_jobs_oldschool object
7 elsif object.components.is_a? Hash
8 pipeline_jobs_newschool object
12 def render_pipeline_jobs
13 pipeline_jobs.collect do |pj|
14 render_pipeline_job pj
18 def render_pipeline_job pj
19 pj[:progress_bar] = render partial: 'job_progress', locals: {:j => pj[:job]}
20 pj[:output_link] = link_to_if_arvados_object pj[:output]
21 pj[:job_link] = link_to_if_arvados_object pj[:job][:uuid]
27 def pipeline_jobs_newschool object
31 jobuuids = object.components.select { |cname, c| c[:job] and c[:job][:uuid] }
33 Job.where(uuid: jobuuids).each do |j|
37 object.components.each do |cname, c|
39 pj = {index: i, name: cname}
44 if c[:job] and c[:job][:uuid]
45 pj[:job] = job[c[:job][:uuid]]
47 pj[:job] = c[:job].is_a?(Hash) ? c[:job] : {}
50 pj[:percent_running] = 0
54 pj[:percent_done] = 100
59 if pj[:job][:tasks_summary]
61 ts = pj[:job][:tasks_summary]
62 denom = ts[:done].to_f + ts[:running].to_f + ts[:todo].to_f
63 pj[:progress] = (ts[:done].to_f + ts[:running].to_f/2) / denom
64 pj[:percent_done] = 100.0 * ts[:done].to_f / denom
65 pj[:percent_running] = 100.0 * ts[:running].to_f / denom
66 pj[:progress_detail] = "#{ts[:done]} done #{ts[:running]} run #{ts[:todo]} todo"
69 pj[:percent_done] = 0.0
70 pj[:percent_running] = 100.0
77 pj[:result] = 'complete'
78 pj[:labeltype] = 'success'
81 elsif pj[:job][:finished_at]
82 pj[:result] = 'failed'
83 pj[:labeltype] = 'danger'
85 elsif pj[:job][:started_at]
86 pj[:result] = 'running'
87 pj[:labeltype] = 'primary'
89 pj[:result] = 'queued'
90 pj[:labeltype] = 'default'
93 pj[:labeltype] = 'default'
95 pj[:job_id] = pj[:job][:uuid]
96 pj[:script] = pj[:job][:script] || c[:script]
97 pj[:script_parameters] = pj[:job][:script_parameters] || c[:script_parameters]
98 pj[:script_version] = pj[:job][:script_version] || c[:script_version]
99 pj[:output] = pj[:job][:output]
100 pj[:finished_at] = (Time.parse(pj[:job][:finished_at]) rescue nil)
106 def pipeline_jobs_oldschool object
108 object.components[:steps].each_with_index do |step, i|
109 pj = {index: i, name: step[:name]}
110 if step[:complete] and step[:complete] != 0
111 if step[:output_data_locator]
117 if step[:progress] and
118 (re = step[:progress].match /^(\d+)\+(\d+)\/(\d+)$/)
119 pj[:progress] = (((re[1].to_f + re[2].to_f/2) / re[3].to_f) rescue 0.5)
124 pj[:result] = 'failed'
128 if step[:warehousejob]
130 pj[:result] = 'complete'
133 elsif step[:warehousejob][:finishtime]
134 pj[:result] = 'failed'
136 elsif step[:warehousejob][:starttime]
137 pj[:result] = 'running'
139 pj[:result] = 'queued'
142 pj[:progress_detail] = (step[:progress] rescue nil)
143 pj[:job_id] = (step[:warehousejob][:id] rescue nil)
144 pj[:job_link] = pj[:job_id]
145 pj[:script] = step[:function]
146 pj[:script_version] = (step[:warehousejob][:revision] rescue nil)
147 pj[:output] = step[:output_data_locator]
148 pj[:finished_at] = (Time.parse(step[:warehousejob][:finishtime]) rescue nil)