10793: Fix to return tuple for alternate exit points --create/update-workflow and...
authorPeter Amstutz <peter.amstutz@curoverse.com>
Thu, 5 Jan 2017 20:29:57 +0000 (15:29 -0500)
committerPeter Amstutz <peter.amstutz@curoverse.com>
Thu, 5 Jan 2017 20:29:57 +0000 (15:29 -0500)
sdk/cwl/arvados_cwl/__init__.py

index 4288c166239c1b89877179db389c8e54d239bcf3..3ffc4c7254a0b8a850716e82aebe6bbd1afb3c26 100644 (file)
@@ -344,13 +344,13 @@ class ArvCwlRunner(object):
                                       name=kwargs.get("name"))
                 tmpl.save()
                 # cwltool.main will write our return value to stdout.
-                return tmpl.uuid
+                return (tmpl.uuid, "success")
             else:
-                return upload_workflow(self, tool, job_order,
+                return (upload_workflow(self, tool, job_order,
                                        self.project_uuid,
                                        uuid=existing_uuid,
                                        submit_runner_ram=kwargs.get("submit_runner_ram"),
-                                       name=kwargs.get("name"))
+                                        name=kwargs.get("name")), "success")
 
         self.ignore_docker_for_reuse = kwargs.get("ignore_docker_for_reuse")
 
@@ -404,7 +404,7 @@ class ArvCwlRunner(object):
 
         if runnerjob and not kwargs.get("wait"):
             runnerjob.run(wait=kwargs.get("wait"))
-            return runnerjob.uuid
+            return (runnerjob.uuid, "success")
 
         self.poll_api = arvados.api('v1')
         self.polling_thread = threading.Thread(target=self.poll_states)