dag-api / Exports / DagObservabilityController
Class: DagObservabilityController
API controller for DAG observability: run projections, lineage, and dashboards.
See
ProjectionReadModelService
Table of contents
Constructors
Methods
Constructors
constructor
• new DagObservabilityController(projectionService): DagObservabilityController
Parameters
| Name | Type |
|---|---|
projectionService | ProjectionReadModelService |
Returns
Defined in
controllers/dag-observability-controller.ts:15
Methods
queryRunProjection
▸ queryRunProjection(request): Promise<TObservabilityApiResponse<IRunProjection>>
Queries the run projection for a specific DAG run.
Parameters
| Name | Type | Description |
|---|---|---|
request | IQueryRunProjectionRequest | The query request with dagRunId. |
Returns
Promise<TObservabilityApiResponse<IRunProjection>>
Run projection data or problem details on error.
Defined in
controllers/dag-observability-controller.ts:22
queryLineageProjection
▸ queryLineageProjection(request): Promise<TObservabilityApiResponse<ILineageProjection>>
Queries the lineage projection for a specific DAG run.
Parameters
| Name | Type | Description |
|---|---|---|
request | IQueryLineageProjectionRequest | The query request with dagRunId. |
Returns
Promise<TObservabilityApiResponse<ILineageProjection>>
Lineage projection data or problem details on error.
Defined in
controllers/dag-observability-controller.ts:51
queryDashboard
▸ queryDashboard(request): Promise<TObservabilityApiResponse<IObservabilityDashboardData>>
Queries the combined dashboard with run and lineage projections.
Parameters
| Name | Type | Description |
|---|---|---|
request | IQueryRunProjectionRequest | The query request with dagRunId. |
Returns
Promise<TObservabilityApiResponse<IObservabilityDashboardData>>
Dashboard data or problem details on error.