Fix ruff format issues

Co-Authored-By: AJ Steers <[email protected]>

Author: devin-ai-integration[bot]

airbyte_cdk/sources/abstract_source.py

@@ -198,9 +198,9 @@ def read(
                         logger.info(timer.report())
 
         if len(stream_name_to_exception) > 0:
-            error_message = generate_failed_streams_error_message({
-                key: [value] for key, value in stream_name_to_exception.items()
-            })
+            error_message = generate_failed_streams_error_message(
+                {key: [value] for key, value in stream_name_to_exception.items()}
+            )
             logger.info(error_message)
             # We still raise at least one exception when a stream raises an exception because the platform currently relies
             # on a non-zero exit code to determine if a sync attempt has failed. We also raise the exception as a config_error

airbyte_cdk/sources/declarative/retrievers/simple_retriever.py

@@ -715,7 +715,11 @@ def fetch_one(
             )
         except Exception as e:
             # Check if this is a 404 (record not found) - raise RecordNotFoundException
-            if "404" in str(e) or (hasattr(e, "response") and hasattr(e.response, "status_code") and e.response.status_code == 404):
+            if "404" in str(e) or (
+                hasattr(e, "response")
+                and hasattr(e.response, "status_code")
+                and e.response.status_code == 404
+            ):
                 raise RecordNotFoundException(
                     f"Record with primary key {pk_value} not found"
                 ) from e