X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/510bdb4e054a7406dbaece96fc46cc7bc14b2c69..e3483661acc3d26d4532a536bd40ed761c21d7d1:/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 aaeffea24b..5024e95f77 100644 --- a/sdk/cwl/arvados_cwl/crunch_script.py +++ b/sdk/cwl/arvados_cwl/crunch_script.py @@ -97,7 +97,8 @@ def run(): debug = job_order_object["arv:debug"] del job_order_object["arv:debug"] - runner = arvados_cwl.ArvCwlRunner(api_client=arvados.api('v1', model=OrderedJsonModel()), + runner = arvados_cwl.ArvCwlRunner(api_client=arvados.safeapi.ThreadSafeApiCache( + api_params={"model": OrderedJsonModel()}, keep_params={"num_retries": 4}), output_name=output_name, output_tags=output_tags) make_fs_access = functools.partial(CollectionFsAccess, @@ -131,6 +132,7 @@ def run(): args.priority = arvados_cwl.DEFAULT_PRIORITY args.do_validate = True args.disable_js_validation = False + args.tmp_outdir_prefix = "tmp" runner.arv_executor(t, job_order_object, **vars(args)) except Exception as e: