get_dag_dataset_queued_events
Retrieve queued Dataset events for a specific DAG in Apache Airflow to monitor data dependencies and trigger conditions.
Instructions
Get queued Dataset events for a DAG
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | Yes |
Input Schema (JSON Schema)
{
"properties": {
"dag_id": {
"title": "Dag Id",
"type": "string"
}
},
"required": [
"dag_id"
],
"type": "object"
}
Implementation Reference
- src/airflow/dataset.py:128-132 (handler)The handler function implementing the 'get_dag_dataset_queued_events' tool. It takes a dag_id parameter, calls the Airflow DatasetApi to retrieve queued events for the DAG, and returns the response as a text content list.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:11-39 (registration)The get_all_functions() lists all dataset-related tools for registration, including the tuple for 'get_dag_dataset_queued_events' on line 19.def get_all_functions() -> list[tuple[Callable, str, str, bool]]: """Return list of (function, name, description, is_read_only) tuples for registration.""" return [ (get_datasets, "get_datasets", "List datasets", True), (get_dataset, "get_dataset", "Get a dataset by URI", True), (get_dataset_events, "get_dataset_events", "Get dataset events", True), (create_dataset_event, "create_dataset_event", "Create dataset event", False), (get_dag_dataset_queued_event, "get_dag_dataset_queued_event", "Get a queued Dataset event for a DAG", True), (get_dag_dataset_queued_events, "get_dag_dataset_queued_events", "Get queued Dataset events for a DAG", True), ( delete_dag_dataset_queued_event, "delete_dag_dataset_queued_event", "Delete a queued Dataset event for a DAG", False, ), ( delete_dag_dataset_queued_events, "delete_dag_dataset_queued_events", "Delete queued Dataset events for a DAG", False, ), (get_dataset_queued_events, "get_dataset_queued_events", "Get queued Dataset events for a Dataset", True), ( delete_dataset_queued_events, "delete_dataset_queued_events", "Delete queued Dataset events for a Dataset", False, ), ]
- src/main.py:90-92 (registration)The generic registration loop where tools from get_all_functions() (including this one) are added to the MCP app using app.add_tool().for func, name, description, *_ in functions: app.add_tool(func, name=name, description=description)