Skip to content

Get Execution Monitor

GET
/api/v1/executions/{execution_id}/monitor

Get unified monitoring view for an execution.

Combines execution record, DAG, route status, and metrics in a single call. Designed for dashboard rendering without multiple API round-trips.

Args: execution_id: Execution UUID service: Execution service (injected) lineage_service: Lineage service (injected)

Returns: Unified monitoring view with execution, DAG, routes, and metrics

Raises: HTTPException: 404 if not found

execution_id
required
Execution Id
string

Successful Response

MonitorResponse

Unified monitoring view for an execution.

Combines: execution record, DAG structure, route status, and metrics. Single endpoint for dashboard rendering.

object
execution_id
required
Execution Id

Execution ID

string format: uuid
config_id
required
Config Id

Configuration ID

string format: uuid
status
required
Status

Execution status

string
Allowed values: running completed failed cancelled interrupted
started_at
required
Started At

Execution start time

string format: date-time
completed_at
Any of:
string format: date-time
dag
required
DAGResponse

Pipeline DAG structure

object
execution_id
required
Execution Id

Execution ID

string format: uuid
init_queue
Any of:
string
nodes
Nodes

Route nodes

Array<object>
DAGNode

A node in the pipeline DAG representing a route.

object
route_id
required
Route Id

Route identifier

string
name
required
Name

Human-readable route name

string
adapters
Adapters

Adapter types in this route

Array<string>
edges
Edges

Queue connections between routes

Array<object>
DAGEdge

An edge in the pipeline DAG representing queue connection.

object
from_route
required
From Route

Source route ID

string
to_route
required
To Route

Target route ID

string
queue
required
Queue

Queue connecting the routes

string
routes
Routes

Per-route status

Array<object>
MonitorRouteStatus

Route status combining runtime and lineage data.

object
route_id
required
Route Id

Route identifier

string
name
required
Name

Human-readable route name

string
lineage_total
Lineage Total

Total messages tracked in lineage

integer
0
lineage_completed
Lineage Completed

Completed messages from lineage

integer
0
lineage_failed
Lineage Failed

Failed messages from lineage

integer
0
lineage_in_progress
Lineage In Progress

In-progress messages from lineage

integer
0
avg_duration_ms
Any of:
number
metrics
required
MonitorMetrics

Aggregated execution metrics

object
total_messages
Total Messages

Total messages processed

integer
0
completed_messages
Completed Messages

Successfully completed messages

integer
0
failed_messages
Failed Messages

Failed messages

integer
0
in_progress_messages
In Progress Messages

Messages currently processing

integer
0

Resource not found

ErrorResponse

Standard error response matching FastAPI HTTPException format.

This model is used in OpenAPI response declarations for 4xx/5xx errors. The detail field matches FastAPI’s HTTPException structure.

object
detail
required
Detail

Error message (matches FastAPI HTTPException)

string
error_code
Any of:
string
correlation_id
Any of:
string
timestamp
Timestamp

Error timestamp

string format: date-time

Validation Error

HTTPValidationError
object
detail
Detail
Array<object>
ValidationError
object
loc
required
Location
Array
msg
required
Message
string
type
required
Error Type
string
input
Input
ctx
Context
object