From c28d1c1d51eab458937f006e2422903797a31dd8 Mon Sep 17 00:00:00 2001
From: octavia-squidington-iii <contact@airbyte.com>
Date: Wed, 13 Nov 2024 05:32:51 +0000
Subject: [PATCH] Auto-fix lint and format issues

---
 .../file_based/stream/concurrent/test_adapters.py  | 14 ++++++++++++--
 .../sources/streams/concurrent/test_adapters.py    |  4 +---
 2 files changed, 13 insertions(+), 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
index acea8a721..aea439735 100644
--- 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
index 0b38d9686..93e8fd212 100644
--- 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,