Updated
On this page
SchedulerBase declares every attribute and cross-mixin abstract method (execute_task, handle_start_task, _run_postchecks, etc.) so mypy resolves references across the Scheduler's mixins.
#scheduler.src.orxtra.scheduler._base
#scheduler.src.orxtra.scheduler._base
Abstract base class for Scheduler mixins.
Declares all shared attributes and cross-mixin methods so mypy can resolve references in any mixin without seeing the concrete Scheduler class.
#SchedulerBase
Abstract base declaring every attribute and cross-mixin method.
Each mixin inherits from this so mypy can resolve self._* attributes and method calls that cross mixin boundaries.
#execute_task
python
async def execute_task(self, task: TaskSpec, parent_task_id: UUID | None, *, task_id: UUID | None=None, variables: dict[str, Any] | None=None) -> TaskResult#abort
python
async def abort(self) -> None#check_active_task
python
def check_active_task(self, session_id: str) -> UUID#handle_start_task
python
async def handle_start_task(self, session_id: str, task_id: str) -> str#handle_end_task
python
async def handle_end_task(self, session_id: str, message: str) -> str#handle_create_task
python
async def handle_create_task(self, session_id: str, params: dict[str, Any]) -> str#handle_create_workflow
python
async def handle_create_workflow(self, session_id: str, params: dict[str, Any]) -> str#handle_create_wait_for
python
async def handle_create_wait_for(self, session_id: str, params: dict[str, Any]) -> str#handle_await_task
python
async def handle_await_task(self, session_id: str, task_id: str) -> str#run_consult
python
async def run_consult(self, agent: str, question: str, variable_values: dict[str, str] | None=None) -> str#run_workflow_check
python
async def run_workflow_check(self, execution: Execution) -> CheckResult