Skip to main content

submit_commands

Function submit_commands 

Source
pub async fn submit_commands<S: WorkflowStore>(
    __arg0: State<Arc<AppState<S>>>,
    __arg1: Path<String>,
    __arg2: Json<SubmitCommandsRequest>,
) -> Result<StatusCode, AppError>
Expand description

Submit a batch of commands a worker produced from running the workflow handler. Each command is processed transactionally (ScheduleActivity inserts a row + appends ActivityScheduled, CompleteWorkflow flips the status + appends WorkflowCompleted, etc.) and the worker’s claim is released on success.