Auto-fix lint and format issues

Author: octavia-squidington-iii

airbyte_cdk/sources/streams/concurrent/state_converters/abstract_stream_state_converter.py

@@ -72,7 +72,9 @@ def deserialize(self, state: MutableMapping[str, Any]) -> MutableMapping[str, An
             stream_slice[self.START_KEY] = self._from_state_message(stream_slice[self.START_KEY])
             stream_slice[self.END_KEY] = self._from_state_message(stream_slice[self.END_KEY])
             if self.MOST_RECENT_RECORD_KEY in stream_slice:
-                stream_slice[self.MOST_RECENT_RECORD_KEY] = self._from_state_message(stream_slice[self.MOST_RECENT_RECORD_KEY])
+                stream_slice[self.MOST_RECENT_RECORD_KEY] = self._from_state_message(
+                    stream_slice[self.MOST_RECENT_RECORD_KEY]
+                )
         return state
 
     def serialize(

unit_tests/sources/streams/concurrent/test_cursor.py

@@ -977,16 +977,18 @@ def test_given_most_recent_cursor_value_in_input_state_when_emit_state_then_seri
             _NO_LOOKBACK_WINDOW,
         )
 
-        cursor.close_partition(_partition(
-            StreamSlice(
-                partition={},
-                cursor_slice={
-                    _LOWER_SLICE_BOUNDARY_FIELD: 20,
-                    _UPPER_SLICE_BOUNDARY_FIELD: 50,
-                },
-            ),
-            _stream_name=_A_STREAM_NAME,
-        ))
+        cursor.close_partition(
+            _partition(
+                StreamSlice(
+                    partition={},
+                    cursor_slice={
+                        _LOWER_SLICE_BOUNDARY_FIELD: 20,
+                        _UPPER_SLICE_BOUNDARY_FIELD: 50,
+                    },
+                ),
+                _stream_name=_A_STREAM_NAME,
+            )
+        )
 
         expected_state = {
             "state_type": ConcurrencyCompatibleStateType.date_range.value,
@@ -998,8 +1000,9 @@ def test_given_most_recent_cursor_value_in_input_state_when_emit_state_then_seri
                 },
             ],
         }
-        self._state_manager.update_state_for_stream.assert_called_once_with(_A_STREAM_NAME, _A_STREAM_NAMESPACE, expected_state)
-
+        self._state_manager.update_state_for_stream.assert_called_once_with(
+            _A_STREAM_NAME, _A_STREAM_NAMESPACE, expected_state
+        )
 
 
 class ClampingIntegrationTest(TestCase):