improve/simplify

Author: aaronsteers

airbyte_cdk/models/airbyte_protocol.py

@@ -1,7 +1,6 @@
 # Copyright (c) 2025 Airbyte, Inc., all rights reserved.
 from collections.abc import Callable
 from dataclasses import InitVar, dataclass
-from functools import cached_property
 from typing import Annotated, Any, Dict, List, Mapping, Optional, Union
 
 import orjson
@@ -101,14 +100,6 @@ class AirbyteMessage:
     trace: Optional[AirbyteTraceMessage] = None  # type: ignore [name-defined]
     control: Optional[AirbyteControlMessage] = None  # type: ignore [name-defined]
 
-    @property
-    def _serializer(self):
-        raise NotImplementedError
-
-    @_serializer.setter
-    def _serializer(self, value):
-        raise NotImplementedError
-
 
 def _with_serdes(
     cls,

airbyte_cdk/models/airbyte_protocol_serializers.py

@@ -14,9 +14,9 @@
 from airbyte_cdk.models.airbyte_protocol import *  # type: ignore[attr-defined]
 
 # Deprecated. Declared here for legacy compatibility:
+AirbyteStreamStateSerializer = AirbyteStreamState._serializer  # type: ignore
 AirbyteStateMessageSerializer = AirbyteStateMessage._serializer  # type: ignore
 AirbyteMessageSerializer = AirbyteMessage._serializer  # type: ignore
-ConnectorSpecificationSerializer = ConnectorSpecification._serializer  # type: ignore
 ConfiguredAirbyteCatalogSerializer = ConfiguredAirbyteCatalog._serializer  # type: ignore
 ConfiguredAirbyteStreamSerializer = ConfiguredAirbyteStream._serializer  # type: ignore
-AirbyteStreamStateSerializer = AirbyteStreamState._serializer  # type: ignore
+ConnectorSpecificationSerializer = ConnectorSpecification._serializer  # type: ignore