pi
end
- helper_method :finished_pipelines
- def finished_pipelines lim
- PipelineInstance.limit(lim).order(["finished_at desc"]).filter([["state", "in", ["Complete", "Failed", "Paused"]], ["finished_at", "!=", nil]])
+ helper_method :recent_processes
+ def recent_processes lim
+ lim = 12 if lim.nil?
+
+ pipelines = PipelineInstance.limit(lim).order(["created_at desc"])
+
+ crs = ContainerRequest.limit(lim).order(["created_at desc"]).filter([["requesting_container_uuid", "=", nil]])
+ cr_uuids = crs.results.collect { |c| c.container_uuid }
+ containers = Container.order(["created_at desc"]).results if cr_uuids.any?
+
+ procs = {}
+ pipelines.results.each { |pi| procs[pi] = pi.created_at }
+ containers.each { |c| procs[c] = c.created_at } if !containers.nil?
+
+ Hash[procs.sort_by {|key, value| value}].keys.reverse.first(lim)
end
helper_method :recent_collections