Avoid initiating session twice in dag_next_execution (apache#35539)

astronomer · Nov 9, 2023 · 9356233 · 9356233
1 parent ad717ef
commit 9356233
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/airflow/cli/commands/dag_command.py b/airflow/cli/commands/dag_command.py
@@ -320,14 +320,14 @@ def dag_next_execution(args) -> None:
     """
     dag = get_dag(args.subdir, args.dag_id)
 
-    if dag.get_is_paused():
-        print("[INFO] Please be reminded this DAG is PAUSED now.", file=sys.stderr)
-
     with create_session() as session:
         last_parsed_dag: DagModel = session.scalars(
             select(DagModel).where(DagModel.dag_id == dag.dag_id)
         ).one()
 
+    if last_parsed_dag.get_is_paused():
+        print("[INFO] Please be reminded this DAG is PAUSED now.", file=sys.stderr)
+
     def print_execution_interval(interval: DataInterval | None):
         if interval is None:
             print(