meanap.pipeline.runner

Top-level pipeline runner, orchestrating steps to mirror MEApipeline.m.

Functions

default_output_folder_name()

Default output folder name, matching MATLAB's 'OutputData' + ddmmmyyyy.

run_pipeline(params[, log, should_cancel])

Run the pipeline steps in [start_analysis_step, stop_analysis_step].
meanap.pipeline.runner.default_output_folder_name()[source]

Default output folder name, matching MATLAB’s 'OutputData' + ddmmmyyyy.

Return type:

str

meanap.pipeline.runner.run_pipeline(params, log=<built-in function print>, should_cancel=None)[source]

Run the pipeline steps in [start_analysis_step, stop_analysis_step].

Creates the same output folder tree as the MATLAB pipeline (CreateOutputFolders.m) up front, then runs each requested step. Steps 1-4 are all implemented (see python/PIPELINE_PORT_STATUS.md for which parts of each step have exact MATLAB parity vs. are deterministic approximations / not yet ported).

should_cancel, if given, is polled at step boundaries and once per recording inside each step; when it returns True the run unwinds by raising PipelineCancelled. Callers that offer a Stop button should catch that and treat it as a clean stop.

Parameters:

  • params (Params)

  • log (Callable[[str], None])

  • should_cancel (Callable[[], bool] | None)

Return type:

Path