Skip to content

Commit

Permalink
Fix CWL
Browse files Browse the repository at this point in the history
  • Loading branch information
joezuntz committed Feb 3, 2022
1 parent 84e9a6d commit e77a681
Showing 1 changed file with 8 additions and 10 deletions.
18 changes: 8 additions & 10 deletions ceci/pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -1284,11 +1284,9 @@ def initiate_run(self, overall_inputs):
inputs_file = f"{cwl_dir}/cwl_inputs.yml"
self.make_inputs_file(self.stages, overall_inputs, self.stages_config, inputs_file)

# CWL treats overall inputs differently, storing
# them in the inputs file. We keep the
self.cwl_overall_inputs = overall_inputs.copy()
overall_inputs.clear()
self.cwl_overall_inputs['config'] = self.stages_config
# CWL treats overall inputs differently, and requires
# that we include the config file in there too
self.overall_inputs['config'] = self.stages_config

return {
"workflow": wf,
Expand Down Expand Up @@ -1318,7 +1316,7 @@ def enqueue_job(self, stage, pipeline_files):
# so not he same as the pipeline_files we usually see
for inp in cwl_tool.inputs:

if (inp.id in self.cwl_overall_inputs):
if (inp.id in self.overall_inputs):
name = inp.id
# If this input is an putput from an earlier stage
# then it takes its name based on that
Expand All @@ -1333,10 +1331,10 @@ def enqueue_job(self, stage, pipeline_files):
name = inp.id

# If it's an overall input to the entire pipeline we
# record that. We only want things that aren't outputs
# (first clause) and that we haven't already recorded (second)
# breakpoint()
if (inp.id in self.cwl_overall_inputs) and (
# record that. Or a configuration option.
# And we don't want things that we've already recorded.
if ((inp.id in self.overall_inputs) or (
inp.id in stage.config_options)) and (
name not in self.run_info["workflow_inputs"]
):
self.run_info["workflow_inputs"].add(name)
Expand Down

0 comments on commit e77a681

Please sign in to comment.