X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/651e87d8d97edebd8d3cd0325dbd15d6dac0cd1c..11377b3b6eb9544b9d9bcabab8de495f6e6fcaa4:/sdk/cwl/arvados_cwl/arvcontainer.py diff --git a/sdk/cwl/arvados_cwl/arvcontainer.py b/sdk/cwl/arvados_cwl/arvcontainer.py index 769a63bce3..e8e2a51131 100644 --- a/sdk/cwl/arvados_cwl/arvcontainer.py +++ b/sdk/cwl/arvados_cwl/arvcontainer.py @@ -14,14 +14,14 @@ import ruamel.yaml as yaml from cwltool.errors import WorkflowException from cwltool.process import get_feature, UnsupportedRequirement, shortname -from cwltool.pathmapper import adjustFileObjs, adjustDirObjs +from cwltool.pathmapper import adjustFileObjs, adjustDirObjs, visit_class from cwltool.utils import aslist import arvados.collection from .arvdocker import arv_docker_get_image from . import done -from .runner import Runner, arvados_jobs_image, packed_workflow, trim_anonymous_location +from .runner import Runner, arvados_jobs_image, packed_workflow, trim_anonymous_location, remove_redundant_fields from .fsaccess import CollectionFetcher from .pathmapper import NoFollowPathMapper, trim_listing from .perf import Perf @@ -286,8 +286,8 @@ class RunnerContainer(Runner): """ adjustDirObjs(self.job_order, trim_listing) - adjustFileObjs(self.job_order, trim_anonymous_location) - adjustDirObjs(self.job_order, trim_anonymous_location) + visit_class(self.job_order, ("File", "Directory"), trim_anonymous_location) + visit_class(self.job_order, ("File", "Directory"), remove_redundant_fields) container_req = { "owner_uuid": self.arvrunner.project_uuid, @@ -316,6 +316,7 @@ class RunnerContainer(Runner): "ram": 1024*1024 * self.submit_runner_ram, "API": True }, + "use_existing": self.enable_reuse, "properties": {} }