---
title: "Stream Freshness Events"
method: GET
path: "/api/v1/assets/{asset_id}/freshness/stream"
tags: ["freshness"]
---

# Stream Freshness Events

`GET /api/v1/assets/{asset_id}/freshness/stream`

## Request

- Base URL: `http://localhost:8000`
- URL: `http://localhost:8000/api/v1/assets/{asset_id}/freshness/stream`
- Auth: none declared

Stream freshness update events via Server-Sent Events.

Provides real-time updates when freshness checks complete.
Authentication via query parameter (EventSource doesn't support headers).

Event format:
{
    "event": "freshness_updated",
    "data": {
        "asset_id": "uuid",
        "table_path": "schema.table",
        "data_freshness": "ready|not_ready|error",
        "timestamp": "ISO8601",
        "last_updated": "ISO8601"
    }
}

Args:
    request: FastAPI request object
    asset_id: Asset UUID to monitor freshness updates for
    token: Authentication token (JWT)
    session: Database session

Returns:
    EventSourceResponse with freshness update events

## Path parameters

- `asset_id` string, uuid, required

## Query parameters

- `token` string, required: Authentication token (JWT)

## Response `200`

Successful Response

- unknown

## Other responses

- `422`: Validation Error

---

[API](https://skmtc.dev/anomalyarmor/apis/anomalyarmor-api.md) · [All operations](https://skmtc.dev/anomalyarmor/apis/anomalyarmor-api/llms.txt) · [OpenAPI document](https://skmtc.dev/anomalyarmor/apis/anomalyarmor-api/revisions/51c755fb5d0b?raw)