airflow-clear-task
Clear and re-run specific task instances in an Airflow DAG run. Optionally include upstream or downstream tasks.
Instructions
Clear specific task instances in an Airflow DAG run (re-run them); supports include_upstream / include_downstream. Write-gated by AIRFLOW_ALLOW_WRITE.
Tool call template
Replace each placeholder with a value matching the input schema. Only required parameters are included; add optional parameters as needed.
{
"id": 1,
"jsonrpc": "2.0",
"method": "tools/call",
"params": {
"arguments": {
"dagId": "<dagId>",
"dagRunId": "<dagRunId>",
"taskIds": "<taskIds>"
},
"name": "airflow-clear-task"
}
}Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dagId | Yes | ||
| dagRunId | Yes | ||
| taskIds | Yes | List of task_ids to clear (and re-run) | |
| includeDownstream | No | ||
| includeUpstream | No |