diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py index beb9b7c3f43f6..bff0b405d081d 100644 --- a/airflow/models/dagrun.py +++ b/airflow/models/dagrun.py @@ -388,6 +388,7 @@ def find_duplicate( @staticmethod def generate_run_id(run_type: DagRunType, execution_date: datetime) -> str: """Generate Run ID based on Run Type and Execution Date""" + execution_date = execution_date.astimezone(tz=timezone.TIMEZONE) return f"{run_type}__{execution_date.isoformat()}" @provide_session