This is an automated email from the ASF dual-hosted git repository. jedcunningham pushed a commit to branch v2-2-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 5fa0e1394e18000bf1ddb4948a92d5f64282e9bc Author: SeonghwanLee <[email protected]> AuthorDate: Thu Jan 27 14:36:24 2022 +0900 Fix 'airflow dags backfill --reset-dagruns' errors when run twice (#21062) Co-authored-by: uplsh <[email protected]> (cherry picked from commit d97e2bac854f9891eb47f0c06c261e89723038ca) --- airflow/cli/commands/dag_command.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/cli/commands/dag_command.py b/airflow/cli/commands/dag_command.py index e04bc73..6e8e157 100644 --- a/airflow/cli/commands/dag_command.py +++ b/airflow/cli/commands/dag_command.py @@ -47,7 +47,7 @@ from airflow.utils.cli import ( ) from airflow.utils.dot_renderer import render_dag from airflow.utils.session import create_session, provide_session -from airflow.utils.state import State +from airflow.utils.state import DagRunState @cli_utils.action_logging @@ -105,7 +105,7 @@ def dag_backfill(args, dag=None): end_date=args.end_date, confirm_prompt=not args.yes, include_subdags=True, - dag_run_state=State.NONE, + dag_run_state=DagRunState.QUEUED, ) try:
