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
pi.each do |pl|
pl.components.each do |k,v|
- if v[:job]
+ if v.is_a? Hash and v[:job]
v[:job] = jobs[v[:job][:uuid]]
end
end