X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/2bf1d2d554c33de560d6d1232c927010ac06e243..876b9e64d1364770486552060222f5f6b1b5e2ea:/sdk/cwl/arvados_cwl/arvcontainer.py diff --git a/sdk/cwl/arvados_cwl/arvcontainer.py b/sdk/cwl/arvados_cwl/arvcontainer.py index 1e79566f40..ae3c668895 100644 --- a/sdk/cwl/arvados_cwl/arvcontainer.py +++ b/sdk/cwl/arvados_cwl/arvcontainer.py @@ -283,11 +283,13 @@ class ArvadosContainer(JobBase): if self.output_ttl < 0: raise WorkflowException("Invalid value %d for output_ttl, cannot be less than zero" % container_request["output_ttl"]) - storage_class_req, _ = self.get_requirement("http://arvados.org/cwl#OutputStorageClass") - if storage_class_req and storage_class_req.get("intermediateStorageClass"): - container_request["output_storage_classes"] = aslist(storage_class_req["intermediateStorageClass"]) - else: - container_request["output_storage_classes"] = runtimeContext.intermediate_storage_classes.strip().split(",") + + if self.arvrunner.api._rootDesc["revision"] >= "20210628": + storage_class_req, _ = self.get_requirement("http://arvados.org/cwl#OutputStorageClass") + if storage_class_req and storage_class_req.get("intermediateStorageClass"): + container_request["output_storage_classes"] = aslist(storage_class_req["intermediateStorageClass"]) + else: + container_request["output_storage_classes"] = runtimeContext.intermediate_storage_classes.strip().split(",") if self.timelimit is not None and self.timelimit > 0: scheduling_parameters["max_run_time"] = self.timelimit @@ -518,10 +520,10 @@ class RunnerContainer(Runner): if runtimeContext.debug: command.append("--debug") - if runtimeContext.storage_classes != "default": + if runtimeContext.storage_classes != "default" and runtimeContext.storage_classes: command.append("--storage-classes=" + runtimeContext.storage_classes) - if runtimeContext.intermediate_storage_classes != "default": + if runtimeContext.intermediate_storage_classes != "default" and runtimeContext.intermediate_storage_classes: command.append("--intermediate-storage-classes=" + runtimeContext.intermediate_storage_classes) if self.on_error: