Mondaic
This API reference is not for the latest stable Salvus version.

salvus.flow.executors.task_chain.local_task_chain_runner

The local object that will actually run the task chains on a remote site.

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: Optional[List[Dict[str, str]]],
    ): ...

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 Optional[List[Dict[str, str]]] — The environment variables per worker.
Methods
run()
def run(self) -> None: ...

Run each task chain, potentially in parallel.

Returns None