projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
11162: Add --submit-request-uuid
[arvados.git]
/
sdk
/
cwl
/
arvados_cwl
/
arvjob.py
diff --git
a/sdk/cwl/arvados_cwl/arvjob.py
b/sdk/cwl/arvados_cwl/arvjob.py
index decd69293178c6f5c4f04d79bc2b7b316f28ac29..04256c68f8b10f47ede2fefcabb0172948c2ff00 100644
(file)
--- a/
sdk/cwl/arvados_cwl/arvjob.py
+++ b/
sdk/cwl/arvados_cwl/arvjob.py
@@
-174,9
+174,6
@@
class ArvadosJob(object):
logger.info("Creating read permission on job %s: %s",
response["uuid"],
e)
logger.info("Creating read permission on job %s: %s",
response["uuid"],
e)
-
- with Perf(metrics, "done %s" % self.name):
- self.done(response)
else:
logger.info("%s %s is %s", self.arvrunner.label(self), response["uuid"], response["state"])
except Exception as e:
else:
logger.info("%s %s is %s", self.arvrunner.label(self), response["uuid"], response["state"])
except Exception as e:
@@
-267,7
+264,6
@@
class ArvadosJob(object):
processStatus = "permanentFail"
finally:
self.output_callback(outputs, processStatus)
processStatus = "permanentFail"
finally:
self.output_callback(outputs, processStatus)
- self.arvrunner.process_done(record["uuid"])
class RunnerJob(Runner):
class RunnerJob(Runner):
@@
-357,9
+353,6
@@
class RunnerJob(Runner):
self.uuid = job["uuid"]
self.arvrunner.process_submitted(self)
self.uuid = job["uuid"]
self.arvrunner.process_submitted(self)
- if job["state"] in ("Complete", "Failed", "Cancelled"):
- self.done(job)
-
class RunnerTemplate(object):
"""An Arvados pipeline template that invokes a CWL workflow."""
class RunnerTemplate(object):
"""An Arvados pipeline template that invokes a CWL workflow."""