Task-level filtering for backfill in Airflow 3 #65298
Replies: 1 comment
-
|
This looks like a real Airflow 3 feature gap, not a hidden flag. The Airflow 3 backfill path is centered on creating DagRuns for a DAG and date range. I do not see an equivalent of the old task regex flag on For now the practical options are to run a full backfill with the unwanted work guarded/short-circuited, use a temporary DAG version for the migration/backfill, or clear selected existing task instances when the DagRuns already exist. A PR for task-scoped backfill would need to define the scheduler semantics carefully, because creating only part of a DAG run interacts with dependencies, mapped tasks, assets, and downstream state. |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
-
Summary
In Airflow 2, the airflow dags backfill command supported the
-tTASK_REGEX flag, which allowed filtering specific task_ids to backfill. When combined with options like-i(--ignore-dependencies), this made it possible to run only selected tasks while skipping upstream dependencies.In Airflow 3, this task-level backfill granularity appears to be missing.
While Airflow 3 still provides airflow tasks clear
--task-regexfor re-running existing task instances, this only works when task instances already exist. It does not help in cases where a new task is added to an existing DAG and needs to be backfilled for historical execution dates.Use case
Suggestion:
Reintroduce task-level backfill functionality to allow selectively backfilling specific tasks within a DAG.
Beta Was this translation helpful? Give feedback.
All reactions