projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
10290: Add scheduling_parameters map to containers and container_requests, and move...
[arvados.git]
/
sdk
/
cwl
/
arvados_cwl
/
crunch_script.py
diff --git
a/sdk/cwl/arvados_cwl/crunch_script.py
b/sdk/cwl/arvados_cwl/crunch_script.py
index 9b0680bc83783e94054f68d1a6376d4d1f5883ae..173eb93daf2c4070ba92f28fca2ac053952f1662 100644
(file)
--- a/
sdk/cwl/arvados_cwl/crunch_script.py
+++ b/
sdk/cwl/arvados_cwl/crunch_script.py
@@
-63,10
+63,15
@@
def run():
adjustDirObjs(job_order_object, functools.partial(getListing, arvados_cwl.fsaccess.CollectionFsAccess("", api_client=api)))
output_name = None
adjustDirObjs(job_order_object, functools.partial(getListing, arvados_cwl.fsaccess.CollectionFsAccess("", api_client=api)))
output_name = None
+ enable_reuse = True
if "arv:output_name" in job_order_object:
output_name = job_order_object["arv:output_name"]
del job_order_object["arv:output_name"]
if "arv:output_name" in job_order_object:
output_name = job_order_object["arv:output_name"]
del job_order_object["arv:output_name"]
+ if "arv:enable_reuse" in job_order_object:
+ enable_reuse = job_order_object["arv:enable_reuse"]
+ del job_order_object["arv:enable_reuse"]
+
runner = arvados_cwl.ArvCwlRunner(api_client=arvados.api('v1', model=OrderedJsonModel()),
output_name=output_name)
runner = arvados_cwl.ArvCwlRunner(api_client=arvados.api('v1', model=OrderedJsonModel()),
output_name=output_name)
@@
-74,7
+79,7
@@
def run():
args = argparse.Namespace()
args.project_uuid = arvados.current_job()["owner_uuid"]
args = argparse.Namespace()
args.project_uuid = arvados.current_job()["owner_uuid"]
- args.enable_reuse =
Tru
e
+ args.enable_reuse =
enable_reus
e
args.submit = False
args.debug = True
args.quiet = False
args.submit = False
args.debug = True
args.quiet = False