Commit 77314eae authored by aknecht2's avatar aknecht2
Browse files

Added transfer option to output files to control whether or not it gets transferred.

parent c3e70cbc
......@@ -362,7 +362,7 @@ class WorkflowJob(object):
- additional_files should be a list of dictionaries:
[{"name": FILE_NAME, "type": "file", "file": FILE_OBJECT},...]
- outputs should be a list of dictionaries:
[{"name": FILE_NAME, "type": "file", "file": FILE_OBJECT},...]
[{"name": FILE_NAME, "transfer": True/False, "type": "file", "file": FILE_OBJECT},...]
if self._params_are_valid(inputs, additional_inputs, outputs):
job = Job(self.executable)
......@@ -373,7 +373,7 @@ class WorkflowJob(object):
for f in param["value"]:
job.uses(f["file"], link=Link.INPUT)
for output_file in outputs:
job.uses(output_file["file"], link=Link.OUTPUT, transfer=True)
job.uses(output_file["file"], link=Link.OUTPUT, transfer=output_file["transfer"])
# Redirect stdout / stderr
if output_file["type"] == "stdout":
......@@ -397,7 +397,8 @@ class WorkflowModule(object):
"name": outputs[param_name],
"file": master_files[outputs[param_name]],
"type": param_info["type"]
"type": param_info["type"],
"transfer": param_info.get("transfer", False)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment