Updated
On this page
ServicesActionExecutor bridges dispatch to services, routing WorkflowAction to start_run_from_file and EventAction to fire_event, both attributed to the system principal.
#services.src.orxtra.services._actions
#services.src.orxtra.services._actions
#ServicesActionExecutor
Concrete ActionExecutor that bridges dispatch to services.
Injects service-level concerns into action execution:
- WorkflowAction: delegates to
start_run_from_file - EventAction: delegates to
fire_event
Satisfies the ActionExecutor protocol from orxtra.dispatch.
#execute_workflow
python
async def execute_workflow(self, workflow_path: str, config: dict[str, object], events: list[dict[str, object]]) -> None#execute_service_action
python
async def execute_service_action(action: Action, events: list[dict[str, object]], *, pool: asyncpg.Pool | None=None, intent_prefix: str='dispatch') -> NoneExecute an action using service-level executors.
Convenience function that wires up a ServicesActionExecutor and an event fire callback, then delegates to dispatch's execute_action.