Minor reformatting

target_postgres/sinks.py

@@ -191,10 +191,10 @@ def _do_copy(
 
                 copy.write_row(processed_row)
     def sanitize_null_text_characters(self, data):
-        """Sanitizes null characters by replacing \u0000 with \uFFFD"""
+        """Sanitizes null characters by replacing \u0000 with \ufffd"""
 
         def replace_null_character(d):
-            return d.replace('\u0000', '\uFFFD')
+            return d.replace("\u0000", "\ufffd")
 
         if isinstance(data, str):
             data = replace_null_character(data)
@@ -211,7 +211,6 @@ def replace_null_character(d):
 
         return data
 
-
     def bulk_insert_records(  # type: ignore[override]
         self,
         table: sa.Table,
@@ -255,7 +254,9 @@ def bulk_insert_records(  # type: ignore[override]
                 }
                 for column in columns:
                     if self.connector.sanitize_null_text_characters:
-                        insert_record[column.name] = self.sanitize_null_text_characters(record.get(column.name))
+                        insert_record[column.name] = self.sanitize_null_text_characters(
+                            record.get(column.name)
+                        )
                     else:
                         insert_record[column.name] = record.get(column.name)
                 # No need to check for a KeyError here because the SDK already
@@ -275,7 +276,9 @@ def bulk_insert_records(  # type: ignore[override]
                 }
                 for column in columns:
                     if self.connector.sanitize_null_text_characters:
-                        insert_record[column.name] = self.sanitize_null_text_characters(record.get(column.name))
+                        insert_record[column.name] = self.sanitize_null_text_characters(
+                            record.get(column.name)
+                        )
                     else:
                         insert_record[column.name] = record.get(column.name)
                 data.append(insert_record)