get_dataset_queued_events
Retrieve queued Dataset events for a specified Dataset URI using the MCP Server for Apache Airflow, enabling efficient monitoring and management of dataset-related workflows.
Instructions
Get queued Dataset events for a Dataset
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| uri | Yes |
Implementation Reference
- src/airflow/dataset.py:155-159 (handler)The handler function that executes the core logic of the 'get_dataset_queued_events' tool by querying the Airflow DatasetApi and formatting the response.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:32-32 (registration)The entry in get_all_functions() that registers the tool with its function reference, name, description, and read-only flag. This list is used by src/main.py to add the tool to the MCP server.(get_dataset_queued_events, "get_dataset_queued_events", "Get queued Dataset events for a Dataset", True),
- src/main.py:96-96 (registration)The code in main.py that registers all tools, including 'get_dataset_queued_events', by calling add_tool in a loop over functions from dataset.py's get_all_functions().app.add_tool(Tool.from_function(func, name=name, description=description))
- src/airflow/dataset.py:8-8 (helper)Initialization of the DatasetApi client used by the handler to interact with Airflow's dataset endpoints.dataset_api = DatasetApi(api_client)