[ARVADOS] created: 2e33c8f2cb71fddb1d7b6b3562c9c29dfa25b87b
git at public.curoverse.com
git at public.curoverse.com
Tue Sep 30 21:51:48 EDT 2014
at 2e33c8f2cb71fddb1d7b6b3562c9c29dfa25b87b (commit)
commit 2e33c8f2cb71fddb1d7b6b3562c9c29dfa25b87b
Author: Peter Amstutz <peter.amstutz at curoverse.com>
Date: Tue Sep 30 21:51:41 2014 -0400
3899: Fix for counting complete/failed components
diff --git a/sdk/cli/bin/arv-run-pipeline-instance b/sdk/cli/bin/arv-run-pipeline-instance
index ded7ab1..c6ccf84 100755
--- a/sdk/cli/bin/arv-run-pipeline-instance
+++ b/sdk/cli/bin/arv-run-pipeline-instance
@@ -652,8 +652,9 @@ class WhRunPipelineInstance
end
end
end
- elsif c[:job][:state] == "Running"
- # Job is still running
+ elsif ["Queued", "Running"].include? c[:job][:state]
+ # Job is running or queued to run, so indicate that pipeline
+ # should continue to run
moretodo = true
elsif c[:job][:state] == "Cancelled"
debuglog "component #{cname} job #{c[:job][:uuid]} cancelled."
@@ -686,11 +687,11 @@ class WhRunPipelineInstance
end
end
- c_in_state = @components.values.group_by { |c|
+ c_in_state = @components.values.group_by { |c|
c[:job] and c[:job][:state]
}
- succeeded = c_in_state["Complete"].count
- failed = c_in_state["Failed"].count + c_in_state["Cancelled"].count
+ succeeded = c_in_state["Complete"].andand.count || 0
+ failed = (c_in_state["Failed"].andand.count || 0) + (c_in_state["Cancelled"].andand.count || 0)
ended = succeeded + failed
success = (succeeded == @components.length)
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list