Retrieve OpenLineage events with pagination and optional filtering.
Returns a paginated list of OpenLineage events, with support for filtering by run ID, job details, event type, and time range. This endpoint is part of the Data Catalog management APIs and is intended for querying stored OpenLineage event data. It supports result pagination through offset and limit parameters.
GET https://[hostname]/api/v1/openlineage/events
Request Parameters
Filtering and pagination
| Parameter | Type | Required | Description |
|---|---|---|---|
| offset | integer | No | Number of records to skip before returning results. |
| limit | integer | No | Maximum number of records to return. |
Additional query parameters
| Parameter | Type | Required | Description |
|---|---|---|---|
| runId | string | No | Filter results by run ID (UUID). |
| jobNamespace | string | No | Filter results by job namespace. |
| jobName | string | No | Filter results by job name. |
| eventType | string | No | Filter results by event type. |
| from | string | No | Return events after this timestamp (ISO 8601). |
| to | string | No | Return events before this timestamp (ISO 8601). |
Request Examples
Each example shows how to call this endpoint with the documented method, URL, headers, and request body format.
curl -X GET "/api/v1/openlineage/events" \
-H "Authorization: Bearer <JWT>"
fetch("/api/v1/openlineage/events", {
method: "GET",
headers: {
"Authorization": "Bearer <JWT>"
}
})
.then(res => res.json())
.then(data => console.log(data));
import json
import requests
url = "/api/v1/openlineage/events"
headers = {
"Authorization": "Bearer <JWT>"
}
payload = None
response = requests.get(url, headers=headers)
print(response.json())
package main
import (
"fmt"
"io"
"net/http"
)
func main() {
body := http.NoBody
req, _ := http.NewRequest("GET", "/api/v1/openlineage/events", body)
req.Header.Set("Authorization", "Bearer <JWT>")
client := &http.Client{}
resp, _ := client.Do(req)
defer resp.Body.Close()
body2, _ := io.ReadAll(resp.Body)
fmt.Println(string(body2))
}
Success Responses
Returns a paginated list of OpenLineage events. The response includes the total number of matching events, pagination details (offset and limit), and event records with identifiers, event type, timing, job details, processing status, and any related assets or relationships.
{
"total": 1,
"offset": 0,
"limit": 50,
"events": [
{
"id": "evt-123e4567-e89b-12d3-a456-426614174000",
"eventType": "COMPLETE",
"eventTime": "2026-04-16T10:30:00Z",
"producer": "https://github.com/dagster-io/dagster",
"runId": "550e8400-e29b-41d4-a716-446655440000",
"jobNamespace": "dagster-prod",
"jobName": "etl_pipeline",
"status": "processed",
"assetsCreated": [
"asset-001"
],
"relationsCreated": [
"relation-001"
],
"createdAt": "2026-04-16T10:30:02Z",
"processedAt": "2026-04-16T10:30:05Z"
}
]
}