delete_dag_dataset_queued_event
Remove a queued Dataset event for a specific DAG in Apache Airflow, ensuring clean event management and system efficiency.
Instructions
Delete 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:135-140 (handler)This is the main handler function implementing the "delete_dag_dataset_queued_event" tool logic. It calls the Airflow dataset_api to delete the specified queued dataset event and returns the response.async def delete_dag_dataset_queued_event( dag_id: str, uri: str, ) -> List[Union[types.TextContent, types.ImageContent, types.EmbeddedResource]]: response = dataset_api.delete_dag_dataset_queued_event(dag_id=dag_id, uri=uri) return [types.TextContent(type="text", text=str(response.to_dict()))]
- src/airflow/dataset.py:20-25 (registration)This tuple within get_all_functions() registers the handler with its name, description, and read-only status (False, meaning mutable). This list is imported and used in src/main.py to add the tool to the MCP server.( delete_dag_dataset_queued_event, "delete_dag_dataset_queued_event", "Delete a queued Dataset event for a DAG", False, ),