Mondaic

salvus.flow.executors.task_chain.local_task_chain_runner

salvus.flow.executors.task_chain.local_task_chain_runner salvus flow executors task_chain local_task_chain_runner

The local task chain runner.

The task chain controller will launch one local task chain runner per node, each of which is responsible for dispatching N task chains running in parallel.

Classes

LocalTaskChainRunner

class LocalTaskChainRunner(builtins.object):
    def __init__(
        self,
        task_chain_paths: dict[str, pathlib.Path],
        number_of_parallel_workers: int,
        environment_variables_per_worker: list[dict[str, str]] | None,
    ): ...

This object will be responsible for running a given list of tasks chains locally.

Parameters
  • task_chain_paths dict[str, pathlib.Path] — Mapping of (identifier, task_chain_path) for each task chain to run with this runner.
  • number_of_parallel_workers int — The number of parallel workers.
  • environment_variables_per_worker list[dict[str, str]] | None — The environment variables per worker.
Methods
run()
def run(self) -> None: ...

Run each task chain, potentially in parallel.

Returns None