dag-runtime / Exports / RunQueryService

Class: RunQueryService

Read-only query service for retrieving DAG run state and associated task runs.

See

IStoragePort for persistence contracts

Table of contents

Constructors

• constructor

Methods

• getRun

Constructors

constructor

• new RunQueryService(storage): RunQueryService

Parameters

Name	Type
storage	IStoragePort

Returns

RunQueryService

Defined in

services/run-query-service.ts:22

Methods

getRun

▸ getRun(dagRunId): Promise<TResult<IRunQueryResult, IDagError>>

Retrieves a DAG run with all its task runs.

Parameters

Name	Type	Description
dagRunId	string	The unique identifier of the DAG run.

Returns

Promise<TResult<IRunQueryResult, IDagError>>

The DAG run and its task runs, or a validation error if not found.

Defined in

services/run-query-service.ts:29