X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/66c13b6055a363cb08197b8c5d040ed9a511c8ca..54bc567a6667783decce679e2ea77b93d5f68322:/apps/workbench/app/helpers/pipeline_instances_helper.rb diff --git a/apps/workbench/app/helpers/pipeline_instances_helper.rb b/apps/workbench/app/helpers/pipeline_instances_helper.rb index b0d5216efd..ac0cbbcccd 100644 --- a/apps/workbench/app/helpers/pipeline_instances_helper.rb +++ b/apps/workbench/app/helpers/pipeline_instances_helper.rb @@ -1,3 +1,7 @@ +# Copyright (C) The Arvados Authors. All rights reserved. +# +# SPDX-License-Identifier: AGPL-3.0 + module PipelineInstancesHelper def pipeline_jobs object=nil @@ -63,15 +67,14 @@ module PipelineInstancesHelper timestamps << [started_at, finished_at] end - # Accept a list of objects with [:started_at] and [:finshed_at] keys and + # Accept a list of objects with [:started_at] and [:finished_at] keys and # merge overlapping ranges to compute the time spent running after periods of # overlapping execution are factored out. def determine_wallclock_runtime jobs timestamps = [] jobs.each do |j| - insert_at = 0 - started_at = j[:started_at] - finished_at = (if j[:finished_at] then j[:finished_at] else Time.now end) + started_at = (j.started_at if j.respond_to?(:started_at)) || (j[:started_at] if j.is_a?(Hash)) + finished_at = (j.finished_at if j.respond_to?(:finished_at)) || (j[:finished_at] if j.is_a?(Hash)) || Time.now if started_at timestamps = merge_range timestamps, started_at, finished_at end @@ -204,7 +207,7 @@ module PipelineInstancesHelper end else if step[:progress] and - (re = step[:progress].match /^(\d+)\+(\d+)\/(\d+)$/) + (re = step[:progress].match(/^(\d+)\+(\d+)\/(\d+)$/)) pj[:progress] = (((re[1].to_f + re[2].to_f/2) / re[3].to_f) rescue 0.5) else pj[:progress] = 0.0 @@ -289,7 +292,7 @@ module PipelineInstancesHelper else s = "" if days > 0 - s += "#{days}d " + s += "#{days}d" end if (hours > 0) @@ -298,7 +301,7 @@ module PipelineInstancesHelper s += "#{minutes}m" - if not round_to_min + if not round_to_min or (days == 0 and hours == 0 and minutes == 0) s += "#{seconds}s" end end @@ -306,4 +309,11 @@ module PipelineInstancesHelper raw(s) end + def render_unreadable_inputs_present + if current_user and controller.class.name.eql?('PipelineInstancesController') and unreadable_inputs_present? + raw('
' + + '

One or more inputs provided are not readable by you. ' + + 'Please correct these before you can run the pipeline.

') + end + end end