orxtra v0.13.0 /dispatch.src.orxtra.dispatch._action_executor
Updated
On this page

Dispatches a single Action by isinstance (ScriptAction, LogAction, WorkflowAction, EventAction, NotifyAction); execute_actions_bounded fans out multiple actions under a concurrency semaphore.

#dispatch.src.orxtra.dispatch._action_executor

#dispatch.src.orxtra.dispatch._action_executor

#execute_action

python
async def execute_action(action: Action, events: list[dict[str, object]], *, workflow_executor: ActionExecutor | None=None, event_fire_callback: EventFireCallback | None=None, notification_port: NotificationPort | None=None) -> None

Dispatch a single action by type.

Follows verify's execute_check pattern: isinstance dispatch on the Action union, hard error on unknown types.

#execute_actions_bounded

python
async def execute_actions_bounded(actions: list[tuple[Action, list[dict[str, object]]]], *, max_concurrent: int, workflow_executor: ActionExecutor | None=None, event_fire_callback: EventFireCallback | None=None, notification_port: NotificationPort | None=None) -> None

Execute multiple actions with bounded concurrency.

Search