chore(deps): Replace pytz.utc with datetime.timezone.utc (#887)

Author: bosper351

airbyte/caches/_state_backend.py

@@ -4,10 +4,9 @@
 
 from __future__ import annotations
 
-from datetime import datetime
+from datetime import datetime, timezone
 from typing import TYPE_CHECKING
 
-from pytz import utc
 from sqlalchemy import Column, DateTime, PrimaryKeyConstraint, String, and_
 from sqlalchemy.orm import Session, declarative_base
 
@@ -59,7 +58,9 @@ class CacheStreamStateModel(SqlAlchemyModel):  # type: ignore[misc]
     """The JSON string representation of the state message."""
 
     last_updated = Column(
-        DateTime(timezone=True), onupdate=datetime.now(utc), default=datetime.now(utc)
+        DateTime(timezone=True),
+        onupdate=datetime.now(timezone.utc),
+        default=datetime.now(timezone.utc),
     )
     """The last time the state was updated."""
 
@@ -89,7 +90,9 @@ class DestinationStreamStateModel(SqlAlchemyModel):  # type: ignore[misc]
     """The JSON string representation of the state message."""
 
     last_updated = Column(
-        DateTime(timezone=True), onupdate=datetime.now(utc), default=datetime.now(utc)
+        DateTime(timezone=True),
+        onupdate=datetime.now(timezone.utc),
+        default=datetime.now(timezone.utc),
     )
     """The last time the state was updated."""
 

airbyte/records.py

@@ -68,10 +68,9 @@
 
 from __future__ import annotations
 
-from datetime import datetime
+from datetime import datetime, timezone
 from typing import TYPE_CHECKING, Any
 
-import pytz
 from uuid_extensions import uuid7str
 
 from airbyte._util.name_normalizers import LowerCaseNormalizer, NameNormalizerBase
@@ -236,7 +235,7 @@ def __init__(
             self.update(
                 {
                     AB_RAW_ID_COLUMN: uuid7str(),
-                    AB_EXTRACTED_AT_COLUMN: extracted_at or datetime.now(pytz.utc),
+                    AB_EXTRACTED_AT_COLUMN: extracted_at or datetime.now(timezone.utc),
                     AB_META_COLUMN: {},
                 }
             )
@@ -254,7 +253,7 @@ def from_record_message(
             from_dict=data_dict,
             stream_record_handler=stream_record_handler,
             with_internal_columns=True,
-            extracted_at=datetime.fromtimestamp(record_message.emitted_at / 1000, tz=pytz.utc),
+            extracted_at=datetime.fromtimestamp(record_message.emitted_at / 1000, tz=timezone.utc),
         )
 
     def __getitem__(self, key: str) -> Any:  # noqa: ANN401

poetry.lock

@@ -38,7 +38,6 @@ pydantic = ">=2.0,<=3.0"
 pydantic-core = "*"
 python-dotenv = "^1.0.1"
 python-ulid = "^3.0.0"
-pytz = "*"
 pyyaml = "^6.0.2"
 requests = "!=3.32.0"  # 3.32.0 breaks docker tests
 rich = "^13.7.0"