- workflowmapper = super(RunnerJob, self).arvados_job_spec(dry_run=dry_run, pull_image=pull_image, **kwargs)
+ if self.tool.tool["id"].startswith("keep:"):
+ self.job_order["cwl:tool"] = self.tool.tool["id"][5:]
+ else:
+ packed = packed_workflow(self.arvrunner, self.tool)
+ wf_pdh = upload_workflow_collection(self.arvrunner, self.name, packed)
+ self.job_order["cwl:tool"] = "%s/workflow.cwl#main" % wf_pdh
+
+ adjustDirObjs(self.job_order, trim_listing)
+ visit_class(self.job_order, ("File", "Directory"), trim_anonymous_location)
+ visit_class(self.job_order, ("File", "Directory"), remove_redundant_fields)
+
+ if self.output_name:
+ self.job_order["arv:output_name"] = self.output_name
+
+ if self.output_tags:
+ self.job_order["arv:output_tags"] = self.output_tags
+
+ self.job_order["arv:enable_reuse"] = self.enable_reuse
+
+ if self.on_error:
+ self.job_order["arv:on_error"] = self.on_error
+
+ if kwargs.get("debug"):
+ self.job_order["arv:debug"] = True