<%# 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 %>
<%= 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 %> <% elsif Job::state(current_job) == "Queued" %>
<% queuetime = Time.now - current_job[:created_at] %> Queued for <%= runtime(queuetime, true) %>. <% begin %> <% if current_job.queue_position == 0 %> This job is next in the queue to run. <% elsif current_job.queue_position == 1 %> There is 1 job in the queue ahead of this one. <% else %> There are <%= current_job.queue_position %> jobs in the queue ahead of this one. <% end %> <% rescue %> <% end %>
<% end %> <% else %>
Not ready
<% end %>
<% current_component = (if current_job then current_job else pj end) %>
<% [:script, :repository, :script_version, :supplied_script_version, :nondeterministic].each do |k| %> <% end %> <% if current_component[:runtime_constraints].andand[:docker_image] and current_component[:docker_image_locator] %> <% else %> <% 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
<% [:uuid, :modified_by_user_uuid, :priority, :created_at, :started_at, :finished_at].each do |k| %> <% end %>
<%= 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 %>
<% if current_component[:tasks_summary] %>
<% [:done, :running, :failed, :todo].each do |d| %> <% end %>
<%= 'tasks:' if d == :done %> <%= d.to_s %> <%= current_component[:tasks_summary][d] %>
<% end %>
<% end %>