airflow-clear-task
Clear and re-run specific task instances in an Airflow DAG run, with options to 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.
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 |