fix: lint

target_bigquery/sinks.py

@@ -16,6 +16,7 @@
 
 from fastavro import parse_schema, writer
 from google.cloud import bigquery
+
 # from google.cloud.bigquery import DEFAULT_RETRY
 
 from singer_sdk.helpers._batch import (
@@ -398,7 +399,8 @@ def transform_record(record):
         try:
             result = load_job.result()
             self.logger.info(
-                f"[{self.stream_name}][{batch_id}] result.eror { result.errors }")
+                f"[{self.stream_name}][{batch_id}] result.eror { result.errors }"
+            )
             # suggested?
             # result = load_job.result(DEFAULT_RETRY.with_deadline(60), 500)
 
@@ -423,15 +425,19 @@ def transform_record(record):
 
         except GoogleAPICallError as e:
             # Handle Google API call errors
-            self.logger.info(f"[{self.stream_name}][{batch_id}] Google API call error: {e}")
+            self.logger.info(
+                f"[{self.stream_name}][{batch_id}] Google API call error: {e}"
+            )
         except TimeoutError:
             # Handle timeout errors
-            self.logger.info(f"[{self.stream_name}][{batch_id}] Timeout error: Job did not complete in the given timeout.")
+            self.logger.info(
+                f"[{self.stream_name}][{batch_id}] Timeout error: Job did not complete in the given timeout."
+            )
         except Exception as e:
             # Handle other unexpected errors
-            self.logger.info(f"[{self.stream_name}][{batch_id}] An unexpected error occurred: {e}")
-
-
+            self.logger.info(
+                f"[{self.stream_name}][{batch_id}] An unexpected error occurred: {e}"
+            )
 
     def process_batch_files(
         self,