get_dag_dataset_queued_events
Retrieve queued dataset events for a specific DAG in Apache Airflow using the MCP Server, enabling efficient monitoring and management of dataset-triggered workflows.
Instructions
Get queued Dataset events for a DAG
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | Yes |
Implementation Reference
- src/airflow/dataset.py:128-132 (handler)The handler function that executes the tool logic by calling the dataset_api.get_dag_dataset_queued_events with the provided dag_id and returning the response as TextContent.async def get_dag_dataset_queued_events( dag_id: str, ) -> List[Union[types.TextContent, types.ImageContent, types.EmbeddedResource]]: response = dataset_api.get_dag_dataset_queued_events(dag_id=dag_id) return [types.TextContent(type="text", text=str(response.to_dict()))]
- src/airflow/dataset.py:19-19 (registration)The registration of the tool in the get_all_functions list, including the function reference, name, description, and read-only flag.(get_dag_dataset_queued_events, "get_dag_dataset_queued_events", "Get queued Dataset events for a DAG", True),