3 <div class="pull-right" style="padding-left: 1em">
4 Current state: <span class="badge badge-info" data-pipeline-state="<%= @object.state %>">
5 <% if @object.state == "RunningOnServer" %>
13 <% pipeline_jobs = render_pipeline_jobs %>
14 <% job_uuids = pipeline_jobs.map { |j| j[:job].andand[:uuid] }.compact %>
15 <% job_uuids_finished = {}; pipeline_jobs.map { |j| job_uuids_finished[j[:job].andand[:uuid]] = j[:job].andand[:finished_at] } %>
17 <% if @object.state == 'Paused' %>
19 This pipeline is paused. Jobs that are
20 already running will continue to run, but no new jobs will be submitted.
24 <% tasks = JobTask.filter([['job_uuid', 'in', job_uuids]]).results %>
25 <% runningtime = determine_wallclock_runtime(pipeline_jobs.map {|j| j[:job]}.compact) %>
28 <% if @object.started_at %>
29 This pipeline started at <%= render_localized_date(@object.started_at) %>.
31 <% if @object.state == 'Complete' %>
33 <% elsif @object.state == 'Failed' %>
39 <% walltime = if @object.finished_at then
40 @object.finished_at - @object.started_at
42 Time.now - @object.started_at
45 <%= if walltime > runningtime
46 render_runtime(walltime, true, false)
48 render_runtime(runningtime, true, false)
49 end %><% if @object.finished_at %> at <%= render_localized_date(@object.finished_at) %><% end %>.
51 This pipeline is <%= if @object.state.start_with? 'Running' then 'active' else @object.state.downcase end %>.
55 <% if @object.state == 'Failed' %>
56 Check the Log tab for more detail about why this pipeline failed.
62 <% if @object.state.start_with? 'Running' %>
68 <% cputime = tasks.map { |task|
70 finished_at = task.finished_at || job_uuids_finished[task.job_uuid] || Time.now()
71 finished_at - task.started_at
76 <%= render_runtime(runningtime, true, false) %><% if (walltime - runningtime) > 0 %>
77 (<%= render_runtime(walltime - runningtime, true, false) %> queued)<% end %><% if cputime == 0 %>.<% else %>
79 <%= render_runtime(cputime, true, false) %>
80 of CPU time (<%= (cputime/runningtime).round(1) %>⨯ scaling).
87 job_uuids = pipeline_jobs.collect {|j| j[:job][:uuid]}.compact
89 resource_class = resource_class_for_uuid(job_uuids.first, friendly_name: true)
90 preload_objects_for_dataclass resource_class, job_uuids
93 job_collections = pipeline_jobs.collect {|j| j[:job][:output]}.compact
94 job_collections.concat pipeline_jobs.collect {|j| j[:job][:docker_image_locator]}.uniq.compact
95 job_collections_pdhs = job_collections.select {|x| !(m = CollectionsHelper.match(x)).nil?}.uniq.compact
96 job_collections_uuids = job_collections - job_collections_pdhs
97 preload_collections_for_objects job_collections_uuids if job_collections_uuids.any?
98 preload_for_pdhs job_collections_pdhs if job_collections_pdhs.any?
101 <% pipeline_jobs.each_with_index do |pj, i| %>
102 <%= render partial: 'running_component', locals: {tasks: tasks, pj: pj, i: i, expanded: false} %>