Skip to content

ChainGraph API Documentation / @badaitech/chaingraph-types / ExecutionEngine

Class: ExecutionEngine ​

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:45

Constructors ​

Constructor ​

new ExecutionEngine(flow, context, options?, onBreakpointHit?): ExecutionEngine

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:62

Parameters ​

flow ​

Flow

context ​

ExecutionContext

options? ​
breakpoints? ​

string[] = ...

debug? ​

boolean = ...

execution? ​

{ flowTimeoutMs?: number; maxConcurrency?: number; nodeTimeoutMs?: number; } = ...

execution.flowTimeoutMs? ​

number = ...

execution.maxConcurrency? ​

number = ...

execution.nodeTimeoutMs? ​

number = ...

onBreakpointHit? ​

(node) => void

Returns ​

ExecutionEngine

Methods ​

createEvent() ​

createEvent<T>(type, data): ExecutionEventImpl<T>

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:770

Type Parameters ​

T ​

T extends ExecutionEventEnum

Parameters ​

type ​

T

data ​

ExecutionEventData[T]

Returns ​

ExecutionEventImpl<T>


execute() ​

execute(onComplete?): Promise<void>

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:90

Parameters ​

onComplete? ​

(context, eventQueue) => Promise<void>

Returns ​

Promise<void>


getDebugger() ​

getDebugger(): DebuggerController | null

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:737

Returns ​

DebuggerController | null


getOptions() ​

getOptions(): { breakpoints?: string[]; debug?: boolean; execution?: { flowTimeoutMs?: number; maxConcurrency?: number; nodeTimeoutMs?: number; }; } | undefined

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:741

Returns ​

{ breakpoints?: string[]; debug?: boolean; execution?: { flowTimeoutMs?: number; maxConcurrency?: number; nodeTimeoutMs?: number; }; } | undefined


on() ​

on<T>(type, handler): () => void

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:745

Type Parameters ​

T ​

T extends ExecutionEventEnum

Parameters ​

type ​

T

handler ​

(event) => void | Promise<void>

Returns ​

(): void

Returns ​

void


onAll() ​

onAll(handler): () => void

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:759

Parameters ​

handler ​

(event) => void | Promise<void>

Returns ​

(): void

Returns ​

void


setEventCallback() ​

setEventCallback(callback): void

Defined in: packages/chaingraph-types/src/flow/execution-engine.ts:766

Set a callback to be called when events are emitted

Parameters ​

callback ​

(context) => Promise<void>

Returns ​

void

Licensed under BUSL-1.1