X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/b6d7efab2c4bffa3fabd55b166e44cca8ac1391f..8991b43990aa7a77edd78f165114b93a6a207985:/sdk/cwl/arvados_cwl/executor.py?ds=sidebyside diff --git a/sdk/cwl/arvados_cwl/executor.py b/sdk/cwl/arvados_cwl/executor.py index 99d4c4e9a1..9ba798ec64 100644 --- a/sdk/cwl/arvados_cwl/executor.py +++ b/sdk/cwl/arvados_cwl/executor.py @@ -42,7 +42,7 @@ from .context import ArvLoadingContext, ArvRuntimeContext from ._version import __version__ from cwltool.process import shortname, UnsupportedRequirement, use_custom_schema -from cwltool.pathmapper import adjustFileObjs, adjustDirObjs, get_listing, visit_class +from cwltool.utils import adjustFileObjs, adjustDirObjs, get_listing, visit_class from cwltool.command_line_tool import compute_checksums from cwltool.load_tool import load_tool @@ -507,7 +507,7 @@ The 'jobs' API is no longer supported. }).execute(num_retries=self.num_retries) except Exception: logger.exception("Setting container output") - return + raise def apply_reqs(self, job_order_object, tool): if "https://w3id.org/cwl/cwl#requirements" in job_order_object: @@ -596,7 +596,8 @@ The 'jobs' API is no longer supported. uuid=existing_uuid, submit_runner_ram=runtimeContext.submit_runner_ram, name=runtimeContext.name, - merged_map=merged_map), + merged_map=merged_map, + submit_runner_image=runtimeContext.submit_runner_image), "success") self.apply_reqs(job_order, tool)