File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
airflow-core/src/airflow/api/common Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -69,14 +69,14 @@ def _trigger_dag(
69
69
raise DagNotFound (f"Dag id { dag_id } not found" )
70
70
71
71
run_after = run_after or timezone .coerce_datetime (timezone .utcnow ())
72
+ coerced_logical_date : datetime | None = None
72
73
if logical_date :
73
74
if not timezone .is_localized (logical_date ):
74
75
raise ValueError ("The logical date should be localized" )
75
76
76
77
if replace_microseconds :
77
78
logical_date = logical_date .replace (microsecond = 0 )
78
79
79
- coerced_logical_date : datetime | None
80
80
if dag .default_args and "start_date" in dag .default_args :
81
81
min_dag_start_date = dag .default_args ["start_date" ]
82
82
if min_dag_start_date and logical_date < min_dag_start_date :
@@ -87,7 +87,6 @@ def _trigger_dag(
87
87
coerced_logical_date = timezone .coerce_datetime (logical_date )
88
88
data_interval = dag .timetable .infer_manual_data_interval (run_after = run_after )
89
89
else :
90
- coerced_logical_date = None
91
90
data_interval = None
92
91
93
92
run_id = run_id or DagRun .generate_run_id (
You can’t perform that action at this time.
0 commit comments