httomo.runner.task_runner.TaskRunner

Contents

httomo.runner.task_runner.TaskRunner#

class httomo.runner.task_runner.TaskRunner(pipeline: Pipeline, reslice_dir: PathLike, comm: mpi4py.MPI.Comm, memory_limit_bytes: int = 0, monitor: MonitoringInterface | None = None)[source]#

Handles the execution of a pipeline

Methods

`__init__`(pipeline, reslice_dir, comm[, ...])
`append_side_outputs`(side_outputs)	Appends to the side outputs that are available for the next section(s)
`determine_max_slices`(section, slicing_dim)
`execute`()
`set_side_inputs`(method)	Sets the parameters that reference side outputs for this method.

append_side_outputs(side_outputs: Dict[str, Any])[source]#: Appends to the side outputs that are available for the next section(s)

determine_max_slices(section: Section, slicing_dim: int)[source]#

execute() → None[source]#

set_side_inputs(method: MethodWrapper)[source]#: Sets the parameters that reference side outputs for this method.