salvus.flow.executors.task_chain.task_chain_runner
salvus.flow.executors.task_chain.task_chain_runner salvus flow executors task_chain task_chain_runner The task chain runner running on remote sites.
Classes
TaskChainRunner
TaskChainRunnerclass TaskChainRunner(builtins.object):
def __init__(
self,
site: BaseExecutor,
task_chain_tasks: dict[str, list],
task_chain_site_config: TaskChainSiteConfig,
context: collections.abc.Callable | None = None,
): ...The task chain runner - it will launch a remote task chain that will spawn the local task chain runner.
Parameters
siteBaseExecutor — The site the task chain runner will run on.task_chain_tasksdict[str, list] — Dictionary of (identifer, tasks) for each task chain to be run on the remote site.task_chain_site_configTaskChainSiteConfig — The site configuration for that site.contextcollections.abc.Callable | None — A optional function returning a context manager that will be used prior to spawning the local task chain runners.
Methods
delete_remote_files()
delete_remote_files()def delete_remote_files(self, verbosity: int = 1) -> None: ...Delete all remote files for this task chain runner.
Parameters
verbosityint — The verbosity.
Returns None
get_status_for_all_task_chains()
get_status_for_all_task_chains()def get_status_for_all_task_chains(self) -> dict[str, JobStatus | None]: ...Get a dictionary with the status of every individual task chain.
This is most useful after the controller finished running.
Returns dict[str, JobStatus | None]
launch()
launch()def launch(self) -> None: ...Asynchronously launch the remote task chain runner. Returns immediately.
Returns None
update_status()
update_status()def update_status(self, force_update: bool = False) -> JobStatus: ...Update the status of the remote task chain runner.
Parameters
force_updatebool — Normally it would only check at most once per a site’s recommended update interval. If this is True, it will check regardless.
Returns JobStatus