X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/6ac7e6d3d1f75cc6d6fe625d2ceaaf00b86a720d..535856c28a12bb07dc986b980b0f4ccfdfd25640:/sdk/cwl/arvados_cwl/__init__.py diff --git a/sdk/cwl/arvados_cwl/__init__.py b/sdk/cwl/arvados_cwl/__init__.py index a7e698b6dc..131795ee2c 100644 --- a/sdk/cwl/arvados_cwl/__init__.py +++ b/sdk/cwl/arvados_cwl/__init__.py @@ -463,6 +463,7 @@ class ArvCwlRunner(object): runtimeContext = runtimeContext.copy() runtimeContext.use_container = True runtimeContext.tmpdir_prefix = "tmp" + runtimeContext.work_api = self.work_api if self.work_api == "containers": if self.ignore_docker_for_reuse: @@ -713,7 +714,7 @@ def arg_parser(): # type: () -> argparse.ArgumentParser parser.add_argument("--submit-runner-ram", type=int, help="RAM (in MiB) required for the workflow runner job (default 1024)", - default=1024) + default=None) parser.add_argument("--submit-runner-image", type=str, help="Docker image for workflow runner job, default arvados/jobs:%s" % __version__, @@ -830,6 +831,8 @@ def main(args, stdout, stderr, api_client=None, keep_client=None, if api_client is None: api_client = arvados.safeapi.ThreadSafeApiCache(api_params={"model": OrderedJsonModel()}, keep_params={"num_retries": 4}) keep_client = api_client.keep + # Make an API object now so errors are reported early. + api_client.users().current().execute() if keep_client is None: keep_client = arvados.keep.KeepClient(api_client=api_client, num_retries=4) runner = ArvCwlRunner(api_client, arvargs, keep_client=keep_client, num_retries=4)