X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/15409c5e2b7946ff7f5fd104a6757a4d874448d4..b1d1c5acf6f237d5e2a02414dd59e92cdb862237:/apps/workbench/app/controllers/application_controller.rb diff --git a/apps/workbench/app/controllers/application_controller.rb b/apps/workbench/app/controllers/application_controller.rb index dc8325cc18..0313111ab9 100644 --- a/apps/workbench/app/controllers/application_controller.rb +++ b/apps/workbench/app/controllers/application_controller.rb @@ -694,24 +694,26 @@ class ApplicationController < ActionController::Base helper_method :running_pipelines def running_pipelines - pi = PipelineInstance.order(["started_at asc", "created_at asc"]).filter([["state", "in", ["RunningOnServer"]]]) + pi = PipelineInstance.order(["started_at asc", "created_at asc"]).filter([["state", "in", ["RunningOnServer", "RunningOnClient"]]]) jobs = {} pi.each do |pl| pl.components.each do |k,v| - if v[:job] + if v.is_a? Hash and v[:job] jobs[v[:job][:uuid]] = {} end end end - Job.filter([["uuid", "in", jobs.keys]]).each do |j| - jobs[j[:uuid]] = j - end + if jobs.keys.any? + Job.filter([["uuid", "in", jobs.keys]]).each do |j| + jobs[j[:uuid]] = j + end - pi.each do |pl| - pl.components.each do |k,v| - if v[:job] - v[:job] = jobs[v[:job][:uuid]] + pi.each do |pl| + pl.components.each do |k,v| + if v.is_a? Hash and v[:job] + v[:job] = jobs[v[:job][:uuid]] + end end end end