delete_dag_dataset_queued_events
Remove queued Dataset events for a specific DAG in Apache Airflow to manage and streamline event processing efficiently.
Instructions
Delete queued Dataset events for a DAG
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| before | No | ||
| dag_id | Yes |
Implementation Reference
- src/airflow/dataset.py:143-152 (handler)The main asynchronous handler function implementing the tool logic. It accepts a dag_id and optional 'before' timestamp, constructs kwargs, calls the underlying Airflow DatasetApi.delete_dag_dataset_queued_events, and returns the response as TextContent.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:26-31 (registration)Registration entry in the get_all_functions() list, associating the handler function with its name, description, and mutability flag (False indicating it mutates data).( delete_dag_dataset_queued_events, "delete_dag_dataset_queued_events", "Delete queued Dataset events for a DAG", False, ),