Auto-fix lint and format issues

airbytehq · Nov 13, 2024 · c28d1c1 · c28d1c1
1 parent 640e7e6
commit c28d1c1
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/unit_tests/sources/file_based/stream/concurrent/test_adapters.py b/unit_tests/sources/file_based/stream/concurrent/test_adapters.py
@@ -124,7 +124,12 @@ def test_file_based_stream_partition(transformer, expected_records):
     cursor_field = None
     state = None
     partition = FileBasedStreamPartition(
-        stream, _slice, message_repository, sync_mode, cursor_field, state,
+        stream,
+        _slice,
+        message_repository,
+        sync_mode,
+        cursor_field,
+        state,
     )
 
     a_log_message = AirbyteMessage(
@@ -203,7 +208,12 @@ def test_file_based_stream_partition_hash(_slice, expected_hash):
     stream = Mock()
     stream.name = "stream"
     partition = FileBasedStreamPartition(
-        stream, _slice, Mock(), _ANY_SYNC_MODE, _ANY_CURSOR_FIELD, _ANY_STATE,
+        stream,
+        _slice,
+        Mock(),
+        _ANY_SYNC_MODE,
+        _ANY_CURSOR_FIELD,
+        _ANY_STATE,
     )
 
     _hash = partition.__hash__()

diff --git a/unit_tests/sources/streams/concurrent/test_adapters.py b/unit_tests/sources/streams/concurrent/test_adapters.py
@@ -115,9 +115,7 @@ def test_stream_partition(transformer, expected_records):
     sync_mode = SyncMode.full_refresh
     cursor_field = None
     state = None
-    partition = StreamPartition(
-        stream, _slice, message_repository, sync_mode, cursor_field, state
-    )
+    partition = StreamPartition(stream, _slice, message_repository, sync_mode, cursor_field, state)
 
     a_log_message = AirbyteMessage(
         type=MessageType.LOG,