chore: additional Python syntax modernization with Ruff unsafe fixes

Co-Authored-By: Aaron <AJ> Steers <aj@airbyte.io>

Author: devin-ai-integration[bot]

airbyte_cdk/destinations/vector_db_based/embedder.py

@@ -252,7 +252,7 @@ def embed_documents(self, documents: list[Document]) -> list[list[float] | None]
                     message=f"Record {str(data)[:250]}... in stream {document.record.stream}  does not contain embedding vector field {self.config.field_name}. Please check your embedding configuration, the embedding vector field has to be set correctly on every record.",
                 )
             field = data[self.config.field_name]
-            if not isinstance(field, list) or not all(isinstance(x, (int, float)) for x in field):
+            if not isinstance(field, list) or not all(isinstance(x, int | float) for x in field):
                 raise AirbyteTracedException(
                     internal_message="Embedding vector field not a list of numbers",
                     failure_type=FailureType.config_error,

airbyte_cdk/sources/declarative/auth/oauth.py

@@ -125,7 +125,7 @@ def __post_init__(self, parameters: Mapping[str, Any]) -> None:
         )
         try:
             if (
-                isinstance(self.token_expiry_date, (int, str))
+                isinstance(self.token_expiry_date, int | str)
                 and str(self.token_expiry_date).isdigit()
             ):
                 self._token_expiry_date = ab_datetime_parse(self.token_expiry_date)

airbyte_cdk/sources/declarative/declarative_stream.py

@@ -230,7 +230,7 @@ def _get_checkpoint_reader(
         checkpoint_mode = self._checkpoint_mode
 
         if isinstance(
-            cursor, (GlobalSubstreamCursor, PerPartitionCursor, PerPartitionWithGlobalCursor)
+            cursor, GlobalSubstreamCursor | PerPartitionCursor | PerPartitionWithGlobalCursor
         ):
             self.has_multiple_slices = True
             return CursorBasedCheckpointReader(

airbyte_cdk/sources/declarative/interpolation/macros.py

@@ -62,7 +62,7 @@ def timestamp(dt: float | str) -> int | float:
     :param dt: datetime to convert to timestamp
     :return: unix timestamp
     """
-    if isinstance(dt, (int, float)):
+    if isinstance(dt, int | float):
         return int(dt)
     else:
         return str_to_datetime(dt).astimezone(pytz.utc).timestamp()

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -872,7 +872,7 @@ def create_legacy_to_per_partition_state_migration(
             )
         partition_router = retriever.partition_router
         if not isinstance(
-            partition_router, (SubstreamPartitionRouterModel, CustomPartitionRouterModel)
+            partition_router, SubstreamPartitionRouterModel | CustomPartitionRouterModel
         ):
             raise ValueError(
                 f"LegacyToPerPartitionStateMigrations can only be applied on a SimpleRetriever with a Substream partition router. Got {type(partition_router)}"
@@ -1757,7 +1757,7 @@ def create_declarative_stream(
             cursor = (
                 combined_slicers
                 if isinstance(
-                    combined_slicers, (PerPartitionWithGlobalCursor, GlobalSubstreamCursor)
+                    combined_slicers, PerPartitionWithGlobalCursor | GlobalSubstreamCursor
                 )
                 else self._create_component_from_model(model=model.incremental_sync, config=config)
             )
@@ -2396,7 +2396,7 @@ def _get_parser(model: BaseModel, config: Config) -> Parser:
                 inner_parser=ModelToComponentFactory._get_parser(model.decoder, config)
             )
         elif isinstance(
-            model, (CustomDecoderModel, IterableDecoderModel, XmlDecoderModel, ZipfileDecoderModel)
+            model, CustomDecoderModel | IterableDecoderModel | XmlDecoderModel | ZipfileDecoderModel
         ):
             raise ValueError(f"Decoder type {model} does not have parser associated to it")
 
@@ -3475,7 +3475,7 @@ def create_config_components_resolver(
     )
 
     def _is_supported_decoder_for_pagination(self, decoder: Decoder) -> bool:
-        if isinstance(decoder, (JsonDecoder, XmlDecoder)):
+        if isinstance(decoder, JsonDecoder | XmlDecoder):
             return True
         elif isinstance(decoder, CompositeRawDecoder):
             return self._is_supported_parser_for_pagination(decoder.parser)

airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py

@@ -373,7 +373,7 @@ def _migrate_child_state_to_parent_state(self, stream_state: StreamState) -> Str
         substream_state = substream_state_values[0] if substream_state_values else {}
 
         # Ignore per-partition states or invalid formats.
-        if isinstance(substream_state, (list, dict)) or len(substream_state_values) != 1:
+        if isinstance(substream_state, list | dict) or len(substream_state_values) != 1:
             # If a global state is present under the key "state", use its first value.
             if (
                 "state" in stream_state

airbyte_cdk/sources/declarative/requesters/error_handlers/default_http_response_filter.py

@@ -24,7 +24,7 @@ def matches(
     ) -> ErrorResolution | None:
         default_mapped_error_resolution = None
 
-        if isinstance(response_or_exception, (requests.Response, Exception)):
+        if isinstance(response_or_exception, requests.Response | Exception):
             mapped_key: int | type = (
                 response_or_exception.status_code
                 if isinstance(response_or_exception, requests.Response)

airbyte_cdk/sources/declarative/requesters/error_handlers/http_response_filter.py

@@ -80,7 +80,7 @@ def matches(
             else response_or_exception.__class__
         )
 
-        if isinstance(mapped_key, (int, Exception)):
+        if isinstance(mapped_key, int | Exception):
             default_mapped_error_resolution = self._match_default_error_mapping(mapped_key)
         else:
             default_mapped_error_resolution = None

airbyte_cdk/sources/declarative/requesters/http_job_repository.py

@@ -230,7 +230,7 @@ def fetch_records(self, job: AsyncJob) -> Iterable[Mapping[str, Any]]:
                 elif isinstance(message, AirbyteMessage):
                     if message.type == Type.RECORD:
                         yield message.record.data  # type: ignore  # message.record won't be None here as the message is a record
-                elif isinstance(message, (dict, Mapping)):
+                elif isinstance(message, dict | Mapping):
                     yield message
                 else:
                     raise TypeError(f"Unknown type `{type(message)}` for message")

airbyte_cdk/sources/declarative/requesters/http_requester.py

@@ -291,7 +291,7 @@ def _request_params(
             raise ValueError("Request params cannot be a string")
 
         for k, v in options.items():
-            if isinstance(v, (dict,)):
+            if isinstance(v, dict):
                 raise ValueError(
                     f"Invalid value for `{k}` parameter. The values of request params cannot be an object."
                 )