[ARVADOS] updated: 1.1.4-189-gf63bd7a
Git user
git at public.curoverse.com
Thu May 3 16:32:32 EDT 2018
Summary of changes:
sdk/cwl/arvados_cwl/__init__.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
via f63bd7af0faad9d0daa8d183d4b722c4bb42f383 (commit)
from 32d79def3a400de6fbe4cd02a8c71643238d867d (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit f63bd7af0faad9d0daa8d183d4b722c4bb42f383
Author: Peter Amstutz <pamstutz at veritasgenetics.com>
Date: Thu May 3 16:18:12 2018 -0400
13365: Fix state logging
Arvados-DCO-1.1-Signed-off-by: Peter Amstutz <pamstutz at veritasgenetics.com>
diff --git a/sdk/cwl/arvados_cwl/__init__.py b/sdk/cwl/arvados_cwl/__init__.py
index b5c9195..d509f40 100644
--- a/sdk/cwl/arvados_cwl/__init__.py
+++ b/sdk/cwl/arvados_cwl/__init__.py
@@ -160,6 +160,7 @@ class ArvCwlRunner(object):
def process_done(self, uuid, record):
with self.workflow_eval_lock:
j = self.processes[uuid]
+ logger.info("%s %s is %s", self.label(j), uuid, record["state"])
self.task_queue.add(partial(j.done, record))
del self.processes[uuid]
@@ -182,7 +183,6 @@ class ArvCwlRunner(object):
j.update_pipeline_component(event["properties"]["new_attributes"])
logger.info("%s %s is Running", self.label(j), uuid)
elif event["properties"]["new_attributes"]["state"] in ("Complete", "Failed", "Cancelled", "Final"):
- logger.info("%s %s is %s", self.label(j), uuid, event["properties"]["new_attributes"]["state"])
self.process_done(uuid, event["properties"]["new_attributes"])
def label(self, obj):
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list