X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/9f842eecf59f293fd800ece28be2730ff3a39487..caf56e922b9caaa9a65332dc6bf3a36bd8fea48f:/sdk/cwl/arvados_cwl/arvworkflow.py diff --git a/sdk/cwl/arvados_cwl/arvworkflow.py b/sdk/cwl/arvados_cwl/arvworkflow.py index d426c1ad6f..f0f9c77f40 100644 --- a/sdk/cwl/arvados_cwl/arvworkflow.py +++ b/sdk/cwl/arvados_cwl/arvworkflow.py @@ -27,9 +27,9 @@ logger = logging.getLogger('arvados.cwl-runner') metrics = logging.getLogger('arvados.cwl-runner.metrics') def upload_workflow(arvRunner, tool, job_order, project_uuid, uuid=None, - submit_runner_ram=0, name=None): + submit_runner_ram=0, name=None, merged_map=None): - packed = packed_workflow(arvRunner, tool) + packed = packed_workflow(arvRunner, tool, merged_map) adjustDirObjs(job_order, trim_listing) adjustFileObjs(job_order, trim_anonymous_location) @@ -158,7 +158,7 @@ class ArvadosWorkflow(Workflow): "inputs": self.tool["inputs"], "outputs": self.tool["outputs"], "stdout": "cwl.output.json", - "requirements": workflowobj["requirements"]+[ + "requirements": self.requirements+[ { "class": "InitialWorkDirRequirement", "listing": [{ @@ -172,8 +172,9 @@ class ArvadosWorkflow(Workflow): "entry": json.dumps(joborder_keepmount, indent=2, sort_keys=True, separators=(',',': ')).replace("\\", "\\\\").replace('$(', '\$(').replace('${', '\${') }] }], - "hints": workflowobj["hints"], - "arguments": ["--no-container", "--move-outputs", "--preserve-entire-environment", "workflow.cwl#main", "cwl.input.yml"] + "hints": self.hints, + "arguments": ["--no-container", "--move-outputs", "--preserve-entire-environment", "workflow.cwl#main", "cwl.input.yml"], + "id": "#" }) kwargs["loader"] = self.doc_loader kwargs["avsc_names"] = self.doc_schema