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

Class: ExecutionService

Defined in: packages/chaingraph-executor/server/services/ExecutionService.ts:47

ExecutionService using dependency injection Works with both local and DBOS modes via interfaces

Implements

• IExecutionService

Constructors

Constructor

new ExecutionService(store, eventBus, taskQueue): ExecutionService

Defined in: packages/chaingraph-executor/server/services/ExecutionService.ts:60

Parameters

store

IExecutionStore

eventBus

IEventBus

taskQueue

ITaskQueue

Returns

ExecutionService

Methods

createExecutionInstance()

createExecutionInstance(params): Promise<ExecutionInstance>

Defined in: packages/chaingraph-executor/server/services/ExecutionService.ts:74

Parameters

params

CreateExecutionParams

Returns

Promise<ExecutionInstance>

Implementation of

IExecutionService.createExecutionInstance

---

getEventBus()

getEventBus(): IEventBus

Defined in: packages/chaingraph-executor/server/services/ExecutionService.ts:70

Get the event bus instance Useful for accessing event bus-specific methods (e.g., closing DBOS streams)

Returns

IEventBus

---

processEmittedEvents()

processEmittedEvents(instance): Promise<void>

Defined in: packages/chaingraph-executor/server/services/ExecutionService.ts:211

Process emitted events and spawn child executions

Parameters

instance

ExecutionInstance

Returns

Promise<void>