Mondaic Documentation
www.mondaic.com
Mondaic
Version:
No results found.
python_api
/
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 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

This object will be responsible for running a given list of tasks chains locally.
SIGNATURE
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,
    ): ...
ARGUMENTS
Required
task_chain_paths
Type:dict[str, pathlib.Path]
Description:
Mapping of (identifier, task_chain_path) for each task chain to run with this runner.
Required
number_of_parallel_workers
Type:int
Description:
The number of parallel workers.
Required
environment_variables_per_worker
Type:list[dict[str, str]] | None
Description:
The environment variables per worker.

Methods

LocalTaskChainRunner.run()
Run each task chain, potentially in parallel.
SIGNATURE
def run(self) -> None: ...
Previous
task_chain
Next
task_chain
We use cookies to analyze our traffic, but won't track you until explicit consent is given. Using our contact form will create relevant cookies and transmit data to third party services to keep track of your request. Read more about how we use personal information in our Privacy Policy.
PAGE CONTENTS