run ruff format

Author: lmossman

airbyte_cdk/connector_builder/connector_builder_handler.py

@@ -108,7 +108,12 @@ def read_stream(
         stream_name = configured_catalog.streams[0].stream.name
 
         stream_read = test_read_handler.run_test_read(
-            source, config, configured_catalog, stream_name, state, limits.max_records, 
+            source,
+            config,
+            configured_catalog,
+            stream_name,
+            state,
+            limits.max_records,
         )
 
         return AirbyteMessage(

airbyte_cdk/connector_builder/test_reader/helpers.py

@@ -268,7 +268,10 @@ def should_close_page_for_slice(at_least_one_page_in_group: bool, message: Airby
     """
     return at_least_one_page_in_group and should_process_slice_descriptor(message)
 
-def is_page_http_request_for_different_stream(json_message: Optional[Dict[str, Any]], stream_name: str) -> bool:
+
+def is_page_http_request_for_different_stream(
+    json_message: Optional[Dict[str, Any]], stream_name: str
+) -> bool:
     """
     Determines whether a given JSON message represents a page HTTP request for a different stream.
 
@@ -285,8 +288,11 @@ def is_page_http_request_for_different_stream(json_message: Optional[Dict[str, A
     Returns:
         bool: True if the JSON message is a page HTTP request for a different stream, False otherwise.
     """
-    return is_page_http_request(json_message) and json_message.get("airbyte_cdk", {}).get("stream", {}).get("name", {}) != stream_name
-    
+    return (
+        is_page_http_request(json_message)
+        and json_message.get("airbyte_cdk", {}).get("stream", {}).get("name", {}) != stream_name
+    )
+
 
 def is_page_http_request(json_message: Optional[Dict[str, Any]]) -> bool:
     """

airbyte_cdk/connector_builder/test_reader/reader.py

@@ -121,7 +121,9 @@ def run_test_read(
 
         schema_inferrer = SchemaInferrer(
             self._pk_to_nested_and_composite_field(stream.primary_key) if stream else None,
-            self._cursor_field_to_nested_and_composite_field(stream.cursor_field) if stream else None,
+            self._cursor_field_to_nested_and_composite_field(stream.cursor_field)
+            if stream
+            else None,
         )
         datetime_format_inferrer = DatetimeFormatInferrer()