get_dataset_queued_events
Retrieve queued events for a specific dataset to monitor data dependencies and track processing status in Apache Airflow workflows.
Instructions
Get queued Dataset events for a Dataset
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| uri | Yes |
Input Schema (JSON Schema)
{
"properties": {
"uri": {
"title": "Uri",
"type": "string"
}
},
"required": [
"uri"
],
"type": "object"
}
Implementation Reference
- src/airflow/dataset.py:155-159 (handler)The handler function implementing the tool logic. It calls the Airflow DatasetApi to get queued events for the given dataset URI and returns the response as MCP TextContent.async def get_dataset_queued_events( uri: str, ) -> List[Union[types.TextContent, types.ImageContent, types.EmbeddedResource]]: response = dataset_api.get_dataset_queued_events(uri=uri) return [types.TextContent(type="text", text=str(response.to_dict()))]
- src/airflow/dataset.py:11-39 (registration)The get_all_functions() that returns the list of tools for the dataset module, including the registration tuple for get_dataset_queued_events.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-91 (registration)The generic registration loop in main.py where app.add_tool is called for each tool from all modules, including this one.for func, name, description, *_ in functions: app.add_tool(func, name=name, description=description)