brain_pipe.runner.default.DefaultRunner

class DefaultRunner(nb_processes: int = -1, logging_config: Dict[str, Any] | Callable | None = {})

Bases: Runner

Default runner for the brain_pipe package.

__init__(nb_processes: int = -1, logging_config: Dict[str, Any] | Callable | None = {})

Create the configuration to the runner.

Parameters:

config (Dict[str, Any]) – Configuration dictionary.

Methods

__init__([nb_processes, logging_config])	Create the configuration to the runner.
run(pipelines_with_loaders)	Run the pipelines with their corresponding dataloaders.

run(pipelines_with_loaders: List[Tuple[DataLoader, Pipeline]])

Run the pipelines with their corresponding dataloaders.

Parameters:

pipelines_with_loaders (List[Tuple[DataLoader, Pipeline]]) – A list of tuples containing a DataLoader and its corresponding Pipeline.

Returns:

The results of the pipelines.

Return type:

List[Any]