delete_dag_dataset_queued_events
Remove queued Dataset events associated with a specific DAG to clean up event queues and manage Airflow dataset dependencies.
Instructions
Delete queued Dataset events for a DAG
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| before | No | ||
| dag_id | Yes |
Input Schema (JSON Schema)
{
"properties": {
"before": {
"anyOf": [
{
"type": "string"
},
{
"type": "null"
}
],
"default": null,
"title": "Before"
},
"dag_id": {
"title": "Dag Id",
"type": "string"
}
},
"required": [
"dag_id"
],
"type": "object"
}
Implementation Reference
- src/airflow/dataset.py:143-152 (handler)The MCP tool handler function that implements the deletion of queued dataset events for a given DAG by invoking the underlying Airflow DatasetApi.async def delete_dag_dataset_queued_events( dag_id: str, before: Optional[str] = None, ) -> List[Union[types.TextContent, types.ImageContent, types.EmbeddedResource]]: kwargs: Dict[str, Any] = {} if before is not None: kwargs["before"] = before response = dataset_api.delete_dag_dataset_queued_events(dag_id=dag_id, **kwargs) return [types.TextContent(type="text", text=str(response.to_dict()))]
- src/airflow/dataset.py:27-31 (registration)Registration of the tool in the get_all_functions() list, which is imported and used in src/main.py to add the tool to the MCP server via app.add_tool().delete_dag_dataset_queued_events, "delete_dag_dataset_queued_events", "Delete queued Dataset events for a DAG", False, ),