X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/9be9761666fd091496bee885b37598db9a6ab38a..44d97727200a7efecd115cd01fb520f371ebfe3b:/apps/workbench/app/views/pipeline_instances/_show_components_running.html.erb diff --git a/apps/workbench/app/views/pipeline_instances/_show_components_running.html.erb b/apps/workbench/app/views/pipeline_instances/_show_components_running.html.erb index b9500f6254..18ae9b08cf 100644 --- a/apps/workbench/app/views/pipeline_instances/_show_components_running.html.erb +++ b/apps/workbench/app/views/pipeline_instances/_show_components_running.html.erb @@ -8,14 +8,18 @@ <% end %>

- This pipeline + <% if @object.started_at %> + Started at <%= @object.started_at %>. + <% end %> + <% if @object.state == 'Complete' %> - completed in + Completed in <% elsif @object.state == 'Failed' %> - failed after + Failed after <% else %> - has been active for + Has been active for <% end %> + <% walltime = if @object.started_at if @object.finished_at @object.finished_at - @object.started_at @@ -26,16 +30,26 @@ 0 end %> - <%= runtime(walltime, true) %>, running for - <% tasks = JobTask.filter([['job_uuid', 'in', render_pipeline_jobs.map { |j| j[:job].andand[:uuid] }]]).results %> + <%= runtime(walltime, true) %><% if @object.finished_at %> at <%= @object.finished_at %><% end %>. - <%# want to buy: algorithm that calculates wall clock runtime that takes into account - concurrent jobs. %> + <% 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]}) %> - <%= runtime(runningtime, true) %><% if tasks.size == 0 %>.<% else %>, - using + <% 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 @@ -60,7 +74,7 @@

- + <%= pj[:name] %>

@@ -111,15 +125,16 @@
<% queuetime = Time.now - current_job[:created_at] %> Queued for <%= runtime(queuetime, true) %>. - There + <% begin %> <% if current_job.queue_position == 0 %> - are no jobs + This job is next in the queue to run. <% elsif current_job.queue_position == 1 %> - is 1 job + There is 1 job in the queue ahead of this one. <% else %> - <%= current_job.queue_position %> jobs + There are <%= current_job.queue_position %> jobs in the queue ahead of this one. <% end %> - ahead of this one. + <% rescue %> + <% end %>
<% end %> <% else %> @@ -131,14 +146,14 @@
-
+
<% current_component = (if current_job then current_job else pj end) %>
- <% [:script, :repository, :supplied_script_version, :script_version, :nondeterministic].each do |k| %> + <% [:script, :repository, :script_version, :supplied_script_version, :nondeterministic].each do |k| %>
<%= k.to_s %>: @@ -187,6 +202,8 @@ <% 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 %>