dag-orchestrator / Exports / OrchestratorRunService

Class: OrchestratorRunService

Table of contents

Constructors

• constructor

Methods

• getDagRunId
• getPendingPromptRequest
• getPendingDefinition
• recordEvent
• createRun
• startRun
• createAndStartRun
• getRunStatus
• getRunResult

Constructors

constructor

• new OrchestratorRunService(promptClient): OrchestratorRunService

Parameters

Name	Type
promptClient	IPromptApiClientPort

Returns

OrchestratorRunService

Defined in

services/orchestrator-run-service.ts:260

Methods

getDagRunId

▸ getDagRunId(preparationId): undefined | string

Parameters

Name	Type
preparationId	string

Returns

undefined | string

Defined in

services/orchestrator-run-service.ts:34

---

getPendingPromptRequest

▸ getPendingPromptRequest(preparationId): undefined | IPromptRequest

Parameters

Name	Type
preparationId	string

Returns

undefined | IPromptRequest

Defined in

services/orchestrator-run-service.ts:38

---

getPendingDefinition

▸ getPendingDefinition(preparationId): undefined | IDagDefinition

Parameters

Name	Type
preparationId	string

Returns

undefined | IDagDefinition

Defined in

services/orchestrator-run-service.ts:44

---

recordEvent

▸ recordEvent(dagRunId, event): void

Parameters

Name	Type
dagRunId	string
event	TRunProgressEvent

Returns

void

Defined in

services/orchestrator-run-service.ts:61

---

createRun

▸ createRun(definition, input): Promise<TResult<{ preparationId: string }, IDagError>>

Parameters

Name	Type
definition	IDagDefinition
input	TPortPayload

Returns

Promise<TResult<{ preparationId: string }, IDagError>>

Defined in

services/orchestrator-run-service.ts:74

---

startRun

▸ startRun(preparationId): Promise<TResult<{ dagRunId: string ; preparationId: string }, IDagError>>

Parameters

Name	Type
preparationId	string

Returns

Promise<TResult<{ dagRunId: string ; preparationId: string }, IDagError>>

Defined in

services/orchestrator-run-service.ts:99

---

createAndStartRun

▸ createAndStartRun(definition, input): Promise<TResult<{ dagRunId: string ; preparationId: string }, IDagError>>

Parameters

Name	Type
definition	IDagDefinition
input	TPortPayload

Returns

Promise<TResult<{ dagRunId: string ; preparationId: string }, IDagError>>

Defined in

services/orchestrator-run-service.ts:139

---

getRunStatus

▸ getRunStatus(dagRunId): Promise<TResult<{ status: TRunStatus }, IDagError>>

Parameters

Name	Type
dagRunId	string

Returns

Promise<TResult<{ status: TRunStatus }, IDagError>>

Defined in

services/orchestrator-run-service.ts:150

---

getRunResult

▸ getRunResult(dagRunId): Promise<TResult<IRunResult, IDagError>>

Parameters

Name	Type
dagRunId	string

Returns

Promise<TResult<IRunResult, IDagError>>

Defined in

services/orchestrator-run-service.ts:179