X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/b48ecbe3e278981ee2ed0df98a5918b4c8e2151c..2e74236fa27822addd856f194befc28382990ce0:/sdk/cwl/arvados_cwl/context.py diff --git a/sdk/cwl/arvados_cwl/context.py b/sdk/cwl/arvados_cwl/context.py index 48f92b77f4..64f85e2076 100644 --- a/sdk/cwl/arvados_cwl/context.py +++ b/sdk/cwl/arvados_cwl/context.py @@ -9,8 +9,6 @@ class ArvLoadingContext(LoadingContext): def __init__(self, kwargs=None): super(ArvLoadingContext, self).__init__(kwargs) -ClusterTarget = namedtuple("ClusterTarget", ("instance", "cluster_id", "owner_uuid")) - class ArvRuntimeContext(RuntimeContext): def __init__(self, kwargs=None): self.work_api = None @@ -31,12 +29,30 @@ class ArvRuntimeContext(RuntimeContext): self.wait = True self.cwl_runner_job = None self.storage_classes = "default" + self.intermediate_storage_classes = "default" self.current_container = None self.http_timeout = 300 self.submit_runner_cluster = None self.cluster_target_id = 0 + self.always_submit_runner = False + self.collection_cache_size = 256 + self.match_local_docker = False + self.enable_preemptible = None + self.copy_deps = None super(ArvRuntimeContext, self).__init__(kwargs) if self.submit_request_uuid: self.submit_runner_cluster = self.submit_request_uuid[0:5] + + def get_outdir(self) -> str: + """Return self.outdir or create one with self.tmp_outdir_prefix.""" + return self.outdir + + def get_tmpdir(self) -> str: + """Return self.tmpdir or create one with self.tmpdir_prefix.""" + return self.tmpdir + + def create_tmpdir(self) -> str: + """Return self.tmpdir or create one with self.tmpdir_prefix.""" + return self.tmpdir