ChainGraph API Documentation / @badaitech/chaingraph-executor / server / executeFlowAtomic

Function: executeFlowAtomic()

executeFlowAtomic(task, abortController, commandController): Promise<ExecutionResult>

Defined in: packages/chaingraph-executor/server/dbos/steps/ExecuteFlowAtomicStep.ts:194

Execute a chaingraph flow atomically

This is a single, indivisible operation that encompasses the entire execution lifecycle. If this step fails at any point, DBOS will automatically retry it on another worker.

Parameters

task

ExecutionTask

Execution task containing executionId and flowId

abortController

AbortController

Abort controller from workflow level (for STOP command)

commandController

CommandController

Command controller from workflow level (for PAUSE/RESUME/STEP)

Returns

Promise<ExecutionResult>

Execution result with status and duration