delete_dataset_queued_events
Remove queued Dataset events from Apache Airflow to manage event backlog and maintain system performance.
Instructions
Delete queued Dataset events for a Dataset
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| before | No | ||
| uri | Yes |
Implementation Reference
- src/airflow/dataset.py:162-171 (handler)The handler function implementing the 'delete_dataset_queued_events' tool. It accepts a dataset URI and optional 'before' timestamp, calls the Airflow DatasetApi to delete queued events, and returns the response as text content.async def delete_dataset_queued_events( uri: 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_dataset_queued_events(uri=uri, **kwargs) return [types.TextContent(type="text", text=str(response.to_dict()))]
- src/airflow/dataset.py:33-38 (registration)Registration entry for the 'delete_dataset_queued_events' tool in the get_all_functions() list, including the handler function, tool name, description, and mutability flag (False).( delete_dataset_queued_events, "delete_dataset_queued_events", "Delete queued Dataset events for a Dataset", False, ),