salvus.flow.executors.task_chain.task_chain_controller

class StdOutErr(builtins.object):
    def __init__(
        self, stdout: dict | None, stderr: dict | None, timings: dict | None
    ) -> None: ...

def get_diagnosis_string(self) -> str: ...

class TaskChainController(builtins.object):
    def __init__(
        self,
        task_chain_tasks: dict[str, list],
        sites: dict[str, TaskChainSiteConfig],
        task_chain_runner_context: typing.Callable | None = None,
    ): ...

def check_status_of_task_chain_runners(
    self, raise_on_error: bool = True
) -> None: ...

def delete_remote_files(self, verbosity: int = 1) -> None: ...

def get_site_and_remote_path_for_task_chain(
    self, identifier: str
) -> tuple[BaseExecutor, _RemotePathType]: ...

def get_status_for_all_task_chains(self) -> dict[str, JobStatus | None]: ...

def get_stdouterr_for_task_chain(self, identifier: str) -> StdOutErr: ...

def launch(self) -> None: ...

def run(self, assert_no_failed_runners: bool = True) -> None: ...

def update_status(self) -> dict[str, JobStatus]: ...

def wait(self) -> None: ...