diff --git a/airflow/cli/commands/dag_command.py b/airflow/cli/commands/dag_command.py index e04bc7381a2f0..6e8e157e01922 100644 --- a/airflow/cli/commands/dag_command.py +++ b/airflow/cli/commands/dag_command.py @@ -47,7 +47,7 @@ ) 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: