airflow_clear_dag_run
Clear all task instances in a specific DAG run to reset workflow execution, optionally including subDAGs, parent DAGs, or upstream/downstream tasks.
Instructions
Clear all task instances in a specific DAG run (destructive).
Parameters
instance: Instance key (optional; mutually exclusive with ui_url)
ui_url: Airflow UI URL to resolve instance (optional; takes precedence)
dag_id: DAG identifier (required if ui_url not provided)
dag_run_id: DAG run identifier (required if ui_url not provided)
include_subdags: Include subDAGs (optional)
include_parentdag: Include parent DAG (optional)
include_upstream: Include upstream tasks (optional)
include_downstream: Include downstream tasks (optional)
dry_run: If true, perform a dry-run only (optional)
reset_dag_runs: Reset DagRun state (optional)
Returns
Response dict: { "dag_id": str, "dag_run_id": str, "cleared": object, "request_id": str }
Raises: ToolError with compact JSON payload (
code,message,request_id, optionalcontext)
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| instance | No | ||
| ui_url | No | ||
| dag_id | No | ||
| dag_run_id | No | ||
| include_subdags | No | ||
| include_parentdag | No | ||
| include_upstream | No | ||
| include_downstream | No | ||
| dry_run | No | ||
| reset_dag_runs | No |