X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/82cd0096558b94f8ff1e23d6e3f8b8dfec7df7b9..b9d2799dfebae724dda3b3e28641116ca5daf5c7:/sdk/cwl/arvados_cwl/__init__.py diff --git a/sdk/cwl/arvados_cwl/__init__.py b/sdk/cwl/arvados_cwl/__init__.py index 57b1bc11a3..7ebb13f1bb 100644 --- a/sdk/cwl/arvados_cwl/__init__.py +++ b/sdk/cwl/arvados_cwl/__init__.py @@ -24,7 +24,7 @@ import arvados.config from .arvcontainer import ArvadosContainer, RunnerContainer from .arvjob import ArvadosJob, RunnerJob, RunnerTemplate -from. runner import Runner +from. runner import Runner, upload_instance from .arvtool import ArvadosCommandTool from .arvworkflow import ArvadosWorkflow, upload_workflow from .fsaccess import CollectionFsAccess @@ -64,6 +64,8 @@ class ArvCwlRunner(object): self.pipeline = None self.final_output_collection = None self.output_name = output_name + self.project_uuid = None + if keep_client is not None: self.keep_client = keep_client else: @@ -266,6 +268,8 @@ class ArvCwlRunner(object): kwargs["docker_outdir"] = "$(task.outdir)" kwargs["tmpdir"] = "$(task.tmpdir)" + upload_instance(self, shortname(tool.tool["id"]), tool, job_order) + runnerjob = None if kwargs.get("submit"): if self.work_api == "containers":