get_dag_dataset_queued_event
Retrieve queued Dataset events for Airflow DAGs to monitor data pipeline triggers and dependencies.
Instructions
Get a queued Dataset event for a DAG
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | Yes | ||
| uri | Yes |
Implementation Reference
- src/airflow/dataset.py:120-125 (handler)The main handler function that executes the tool logic: calls the Airflow dataset_api to retrieve the queued Dataset event for a given DAG ID and URI, then formats the response as MCP TextContent.
async def get_dag_dataset_queued_event( dag_id: str, uri: str, ) -> List[Union[types.TextContent, types.ImageContent, types.EmbeddedResource]]: response = dataset_api.get_dag_dataset_queued_event(dag_id=dag_id, uri=uri) return [types.TextContent(type="text", text=str(response.to_dict()))] - src/airflow/dataset.py:18-18 (registration)Registers the tool in the get_all_functions() list with its name, description, and read-only flag.
(get_dag_dataset_queued_event, "get_dag_dataset_queued_event", "Get a queued Dataset event for a DAG", True),