list_asset_events
Retrieve and filter asset update events from Apache Airflow to track data dependencies, debug scheduling issues, and monitor pipeline outputs.
Instructions
List asset/dataset events with optional filtering.
Use this tool when the user asks about:
"What asset events were produced by DAG X?"
"Show me dataset events from run Y"
"Debug why downstream DAG wasn't triggered"
"What assets did this pipeline produce?"
"List recent asset update events"
Asset events are produced when a task updates an asset/dataset. These events can trigger downstream DAGs that depend on those assets (data-aware scheduling).
Returns event information including:
uri: The asset that was updated
source_dag_id: The DAG that produced this event
source_run_id: The DAG run that produced this event
source_task_id: The task that produced this event
timestamp: When the event was created
Args: source_dag_id: Filter events by the DAG that produced them source_run_id: Filter events by the DAG run that produced them source_task_id: Filter events by the task that produced them limit: Maximum number of events to return (default: 100)
Returns: JSON with list of asset events
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| source_dag_id | No | ||
| source_run_id | No | ||
| source_task_id | No | ||
| limit | No |