X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/98fcb678a39f72945a9c947315beb31178bd4fc3..c14246b9a21d038fc6fa850f4032659a98397784:/sdk/cwl/arvados_cwl/arvcontainer.py?ds=sidebyside diff --git a/sdk/cwl/arvados_cwl/arvcontainer.py b/sdk/cwl/arvados_cwl/arvcontainer.py index c0d82d9585..e7cd617bae 100644 --- a/sdk/cwl/arvados_cwl/arvcontainer.py +++ b/sdk/cwl/arvados_cwl/arvcontainer.py @@ -42,6 +42,7 @@ class ArvadosContainer(object): "kind": "tmp" } } + scheduling_parameters = {} dirs = set() for f in self.pathmapper.files(): @@ -102,11 +103,12 @@ class ArvadosContainer(object): partition_req, _ = get_feature(self, "http://arvados.org/cwl#PartitionRequirement") if partition_req: - runtime_constraints["partition"] = aslist(partition_req["partition"]) + scheduling_parameters["partitions"] = aslist(partition_req["partition"]) container_request["mounts"] = mounts container_request["runtime_constraints"] = runtime_constraints container_request["use_existing"] = kwargs.get("enable_reuse", True) + container_request["scheduling_parameters"] = scheduling_parameters try: response = self.arvrunner.api.container_requests().create( @@ -189,6 +191,9 @@ class RunnerContainer(Runner): if self.output_name: command.append("--output-name=" + self.output_name) + if self.output_tags: + command.append("--output-tags=" + self.output_tags) + if self.enable_reuse: command.append("--enable-reuse") else: