tierkreis.controller.executor.task_executor

A meta executor consisting assigning executors to tasks.

Module Contents

Classes

TaskExecutor

A Tierkreis executor that routes tasks to other executors.

API

class tierkreis.controller.executor.task_executor.TaskExecutor(assignments: dict[str, tierkreis.controller.executor.protocol.ControllerExecutor], storage: tierkreis.controller.storage.protocol.ControllerStorage)

A Tierkreis executor that routes tasks to other executors.

Routing is based on the fully qualified task name. The fully qualified task name is of the form <WORKER_NAME>.<TASK_NAME> . Glob syntax can be used to route multiple tasks to the same executor.

Initialization

run(launcher_name: str, worker_call_args_path: pathlib.Path) → tierkreis.controller.storage.data.ExecutorDebugData