Updated
On this page
TaskDispatchMixin executes non-agent task types: decision points, callable/function tasks, composite (subtask tree) tasks, wait_for tasks, and for_each fan-out with concurrency limits.
#scheduler.src.orxtra.scheduler._task_dispatch
#scheduler.src.orxtra.scheduler._task_dispatch
#TaskDispatchMixin
Mixin for composite, function, wait-for, decision-point, and for-each task execution.
#_execute_decision_point_task
python
async def _execute_decision_point_task(self, task: TaskSpec, task_id: UUID) -> TaskResultExecute a decision point task.
Sends an event to the Overseer, which may create tasks, modify constraints, etc. in response.