| - component - | - job - <%# format:'js' here helps browsers avoid using the cached js - content in html context (e.g., duplicate tab -> see - javascript) %> - <%= link_to '(refresh)', {format: :js}, {class: 'refresh hide', remote: true, method: 'get'} %> - | -|||||
|---|---|---|---|---|---|---|
| - <%= pj[:name] %> - |
- <%= pj[:script] %>
- <%= pj[:script_version] %> - | - <%= render(partial: 'job_status_label', locals: { j: pj[:job] }) %> - | - <%= pj[:progress_bar] %> - | - <% current_job = Job.find(pj[:job][:uuid]) rescue nil %> -- <% if current_job %> - <%= render partial: 'show_object_button', locals: {object: current_job, size: 'xs', link_text: 'Show job details'} %> - <% end %> - |
- <% if current_job.andand[:log] %>
- <% fixup = /([a-f0-9]{32}\+\d+)(\+?.*)/.match(current_job[:log])%>
- <% Collection.limit(1).where(uuid: fixup[1]).each do |c| %>
- <% c.files.first.andand do |file| %>
- <%= link_to url_for(controller: 'collections', action: 'show_file', uuid: current_job[:log], file: "#{file[0]}/#{file[1]}", disposition: 'inline', size: file[2]), class: 'btn btn-default btn-xs' do %>
- Show log messages
- <% end %>
- <% end %>
+<%# Summary %>
+
+<% if @object.state == 'Paused' %>
+ + This pipeline is paused. Jobs that are + already running will continue to run, but no new jobs will be submitted. + +<% end %> + ++ <% if @object.started_at %> + Started at <%= @object.started_at %>. + <% end %> + + <% if @object.state == 'Complete' %> + Completed in + <% elsif @object.state == 'Failed' %> + Failed after + <% else %> + Has been active for + <% end %> + + <% walltime = if @object.started_at + if @object.finished_at + @object.finished_at - @object.started_at + else + Time.now - @object.started_at + end + else + 0 + end + %> + + <%= runtime(walltime, true) %><% if @object.finished_at %> at <%= @object.finished_at %><% end %>. + + <% if @object.state == 'Failed' %> + Check the Log tab for more detail about why this pipeline failed. + <% end %> + + ++ <% tasks = JobTask.filter([['job_uuid', 'in', render_pipeline_jobs.map { |j| j[:job].andand[:uuid] }]]).results %> + <% runningtime = determine_wallclock_runtime(render_pipeline_jobs.map {|j| j[:job]}) %> + + <% if @object.state.start_with? 'Running' %> + Has run + <% else %> + Ran + <% end %> + for + <%= runtime(runningtime, true) %> (<%= runtime(walltime - runningtime, true) %> queued)<% if tasks.size == 0 %>.<% else %> + and used + <% cputime = tasks.map { |task| + puts "started at #{task.started_at}" + if task.started_at + (if task.finished_at then task.finished_at else Time.now() end) - task.started_at + else + 0 + end + }.reduce(:+) %> + <%= runtime(cputime, true) %> + of CPU time (<%= (cputime/runningtime).round(1) %>⨯ scaling). + <% end %> + + +<%# Components %> + +<% render_pipeline_jobs.each_index do |i| %> + <% pj = render_pipeline_jobs[i] %> + <% current_job = pj[:job] if pj[:job] != {} %> +
+
+
+
+
+
+
+ <% puts current_job.inspect %>
+
+ <% if current_job %>
+ + + <%= pj[:name] %> + ++
+ <%= render(partial: 'job_status_label', locals: { j: current_job }) %>
+
+
+
+ <% if current_job[:started_at] %>
+ <% walltime = ((if current_job.finished_at then current_job.finished_at else Time.now() end) - current_job.started_at) %>
+ <% cputime = tasks.map { |task|
+ if task.started_at and task.job_uuid == current_job.uuid
+ (if task.finished_at then task.finished_at else Time.now() end) - task.started_at
+ else
+ 0
+ end
+ }.reduce(:+) %>
+ <%= runtime(walltime, false) %> / <%= runtime(cputime, false) %> (<%= (cputime/walltime).round(1) %>⨯)
<% end %>
+
+
+ <% if Job::state(current_job).in? ["Completed", "Failed", "Canceled"] %>
+
+ <% if pj[:output_uuid] %>
+ <%= link_to_if_arvados_object pj[:output_uuid] %>
+ <% elsif current_job.andand[:output] %>
+ <%= link_to_if_arvados_object current_job[:output], link_text: "Output of #{pj[:name]}" %>
+ <% else %>
+ No output.
+ <% end %>
+
+ <% elsif Job::state(current_job) == "Running" %>
+
+ <%= pj[:progress_bar] %>
+
+
+ <%= form_tag "/jobs/#{current_job.uuid}/cancel", style: "display:inline; padding-left: 1em" do |f| %>
+ <%= hidden_field_tag :return_to, url_for(@object) %>
+ <%= button_tag "Cancel", {class: 'btn btn-xs btn-danger', id: "cancel-job-button"} %>
+
<% end %>
- | - <% if current_job.andand[:output] %> - <%= link_to_if_arvados_object current_job[:output], {thumbnail: true, link_text: raw(' Show output files')}, {class: 'btn btn-default btn-xs'} %> - <% end %> - | -
| + <%= k.to_s %>: + | ++ <%= current_component[k] %> + | +
| + docker_image: + | ++ <%= current_component[:runtime_constraints][:docker_image] %> + | +
| + docker_image_locator: + | ++ <%= link_to_if_arvados_object current_component[:docker_image_locator] %> + | +
| + docker_image: + | ++ Not run in Docker + | +
| + <%= k.to_s %>: + | ++ <% if k.to_s.end_with? 'uuid' %> + <%= link_to_if_arvados_object current_component[k], friendly_name: true %> + <% elsif k.to_s.end_with? '_at' %> + <%= current_component[k] %> + <% else %> + <%= current_component[k] %> + <% end %> + | +
script_parameters:
+<%= JSON.pretty_generate(current_component[:script_parameters]) rescue nil %>+
| <%= 'tasks:' if d == :done %> | +<%= d.to_s %> | +<%= current_component[:tasks_summary][d] %> | +