orangeqs.juice.task_manager._router

Module Contents

Classes

TaskRouter

A router that proxies tasks to the correct service.

API

class orangeqs.juice.task_manager._router.TaskRouter(loop: asyncio.AbstractEventLoop, task_manager_config: orangeqs.juice.schemas.task_manager.TaskManagerConfig, task_server_configs: orangeqs.juice.schemas.tasks.TaskServerConfigs, service_task_lock: orangeqs.juice.task_manager._scheduler.ServiceTaskLock | None = None)

A router that proxies tasks to the correct service.

async start() → None

Run the task router server.