X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/a31816b03c8249178d51621524f05437f5f9478a..3088521012dd7f5b88725240cebf163d7c8da31c:/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 1ed9e3ed6b..8e89331cb6 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,7 +67,7 @@ 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 @@ -88,7 +92,7 @@ module PipelineInstancesHelper c[:job][:uuid] if c.is_a?(Hash) and c[:job].is_a?(Hash) }.compact job = {} - Job.where(uuid: jobuuids).each do |j| + Job.where(uuid: jobuuids).with_count("none").each do |j| job[j[:uuid]] = j end @@ -203,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