[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