Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ceci/pipeline/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,5 +11,5 @@
from .dry_run import DryRunPipeline
from .flow_chart import FlowChartPipeline
from .mini import MiniPipeline
from .file_manager import FileManager
from .sec import StageExecutionConfig
from .graph import StageStatus
6 changes: 3 additions & 3 deletions ceci/pipeline/dry_run.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,11 +18,11 @@ def initiate_run(self, overall_inputs):
def should_skip_stage(self, stage):
return False

def enqueue_job(self, stage, pipeline_files):
def enqueue_job(self, stage, input_paths):
outputs = stage.find_outputs(self.run_config["output_dir"])
sec = self.stage_execution_config[stage.instance_name]
sec = self.get_stage_execution_config(stage.instance_name)

cmd = sec.generate_full_command(pipeline_files, outputs, self.stages_config)
cmd = sec.generate_full_command(input_paths, outputs, self.stages_config)

# Replace the first instance of the stage name with bold
# text, but only if we are printing to screen. This helps the
Expand Down
73 changes: 0 additions & 73 deletions ceci/pipeline/file_manager.py

This file was deleted.

Loading
Loading