From ac83e2c56c97311bf115c6343f9c82250796e9b4 Mon Sep 17 00:00:00 2001 From: Ash Berlin-Taylor Date: Tue, 9 Dec 2025 20:11:46 +0000 Subject: [PATCH] Fix an odd import of pendulum from sqlalchemy_utils instead of elsewhere. This was likely a case of auto-complete gone wrong. Most of the time this doesn't matter (as SQLa etc is already loaded) but this was importing it in Task SDK mistakenly which we don't want. Also generally this isn't the right import :) --- airflow-core/src/airflow/dag_processing/bundles/base.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/airflow-core/src/airflow/dag_processing/bundles/base.py b/airflow-core/src/airflow/dag_processing/bundles/base.py index 1ab14abd047fb..2df62bcf2b8f8 100644 --- a/airflow-core/src/airflow/dag_processing/bundles/base.py +++ b/airflow-core/src/airflow/dag_processing/bundles/base.py @@ -32,8 +32,8 @@ from pathlib import Path from typing import TYPE_CHECKING +import pendulum from pendulum.parsing import ParserError -from sqlalchemy_utils.types.enriched_datetime.pendulum_datetime import pendulum from airflow.configuration import conf @@ -98,7 +98,8 @@ class BundleUsageTrackingManager: def _parse_dt(self, val) -> DateTime | None: try: - return pendulum.parse(val) + dt = pendulum.parse(val) + return dt if isinstance(dt, pendulum.DateTime) else None except ParserError: return None