dag-api / Exports / DagDiagnosticsController
Class: DagDiagnosticsController
API controller for DAG diagnostics operations: failure analysis, rerun, and DLQ reinject.
See
IDiagnosticsPolicy
Table of contents
Constructors
Methods
Constructors
constructor
• new DagDiagnosticsController(runQuery, runOrchestrator, dlqReinject, policy?): DagDiagnosticsController
Parameters
| Name | Type |
|---|---|
runQuery | RunQueryService |
runOrchestrator | RunOrchestratorService |
dlqReinject | DlqReinjectService |
policy | IDiagnosticsPolicy |
Returns
Defined in
controllers/dag-diagnostics-controller.ts:55
Methods
analyzeFailure
▸ analyzeFailure(request): Promise<TDiagnosticsApiResponse<IFailureAnalysis>>
Analyzes failures in a DAG run, returning failed tasks and error code counts.
Parameters
| Name | Type | Description |
|---|---|---|
request | IAnalyzeFailureRequest | The failure analysis request. |
Returns
Promise<TDiagnosticsApiResponse<IFailureAnalysis>>
Failure analysis data or problem details on error.
Defined in
controllers/dag-diagnostics-controller.ts:67
rerun
▸ rerun(request): Promise<TDiagnosticsApiResponse<{ sourceDagRunId: string ; rerunDagRunId: string ; dagId: string ; version: number }>>
Triggers a manual rerun of a previously executed DAG run.
Parameters
| Name | Type | Description |
|---|---|---|
request | IRerunRequest | The rerun request with source run ID and input. |
Returns
Promise<TDiagnosticsApiResponse<{ sourceDagRunId: string ; rerunDagRunId: string ; dagId: string ; version: number }>>
New run identifiers or problem details on error.
Defined in
controllers/dag-diagnostics-controller.ts:101
reinjectDeadLetter
▸ reinjectDeadLetter(request): Promise<TDiagnosticsApiResponse<{ reinjected: boolean ; taskRunId?: string }>>
Reinjects a dead letter queue item back into the main processing queue.
Parameters
| Name | Type | Description |
|---|---|---|
request | IReinjectDeadLetterRequest | The reinject request with worker ID and visibility timeout. |
Returns
Promise<TDiagnosticsApiResponse<{ reinjected: boolean ; taskRunId?: string }>>
Reinject status or problem details if disabled by policy.