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

Class: RecoveryService

Defined in: packages/chaingraph-executor/server/services/RecoveryService.ts:22

RecoveryService handles automatic recovery of stuck/failed executions Uses PostgreSQL advisory locks to ensure only one recovery process runs across all workers

Constructors

Constructor

new RecoveryService(store, taskQueue, workerId): RecoveryService

Defined in: packages/chaingraph-executor/server/services/RecoveryService.ts:31

Parameters

store

IExecutionStore

taskQueue

ITaskQueue

workerId

string

Returns

RecoveryService

Methods

start()

start(): Promise<void>

Defined in: packages/chaingraph-executor/server/services/RecoveryService.ts:42

Start the recovery service background process

Returns

Promise<void>

---

stop()

stop(): Promise<void>

Defined in: packages/chaingraph-executor/server/services/RecoveryService.ts:67

Stop the recovery service

Returns

Promise<void>

---

triggerRecoveryScan()

triggerRecoveryScan(): Promise<void>

Defined in: packages/chaingraph-executor/server/services/RecoveryService.ts:89

Manually trigger a recovery scan Useful for immediate recovery after detecting expired claims

Returns

Promise<void>