Skip to content

Commit 940c7bb

Browse files
authored
Use sdk shared library references in serde source code (#59591)
1 parent 667b112 commit 940c7bb

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

task-sdk/src/airflow/sdk/serde/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,9 +29,9 @@
2929

3030
import attr
3131

32-
from airflow.observability.stats import Stats
3332
from airflow.sdk._shared.module_loading import import_string, iter_namespace, qualname
3433
from airflow.sdk.configuration import conf
34+
from airflow.sdk.observability.stats import Stats
3535
from airflow.sdk.serde.typing import is_pydantic_model
3636

3737
if TYPE_CHECKING:

task-sdk/src/airflow/sdk/serde/serializers/datetime.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
from typing import TYPE_CHECKING
2121

22-
from airflow._shared.timezones.timezone import parse_timezone
22+
from airflow.sdk._shared.timezones.timezone import parse_timezone
2323
from airflow.sdk.module_loading import qualname
2424
from airflow.sdk.serde.serializers.timezone import (
2525
deserialize as deserialize_timezone,

task-sdk/src/airflow/sdk/serde/serializers/timezone.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ def serialize(o: object) -> tuple[U, str, int, bool]:
7070
def deserialize(cls: type, version: int, data: object) -> Any:
7171
from zoneinfo import ZoneInfo
7272

73-
from airflow._shared.timezones.timezone import parse_timezone
73+
from airflow.sdk._shared.timezones.timezone import parse_timezone
7474

7575
if not isinstance(data, (str, int)):
7676
raise TypeError(f"{data} is not of type int or str but of {type(data)}")

0 commit comments

Comments
 (0)