Auto-fix lint and format issues

Author: octavia-squidington-iii

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

@@ -82,7 +82,11 @@ def convert_from_sequential_state(
         # The start and end are the same to avoid confusion as to whether the records for this slice
         # were actually synced
         slices = [
-            {self.START_KEY: start if start is not None else sync_start, self.END_KEY: sync_start, self.MOST_RECENT_RECORD_KEY: sync_start}
+            {
+                self.START_KEY: start if start is not None else sync_start,
+                self.END_KEY: sync_start,
+                self.MOST_RECENT_RECORD_KEY: sync_start,
+            }
         ]
 
         return sync_start, {

unit_tests/sources/streams/concurrent/test_cursor.py

@@ -64,7 +64,9 @@ def setUp(self) -> None:
         self._message_repository = Mock(spec=MessageRepository)
         self._state_manager = Mock(spec=ConnectorStateManager)
 
-    def _cursor_with_slice_boundary_fields(self, is_sequential_state: bool = True) -> ConcurrentCursor:
+    def _cursor_with_slice_boundary_fields(
+        self, is_sequential_state: bool = True
+    ) -> ConcurrentCursor:
         return ConcurrentCursor(
             _A_STREAM_NAME,
             _A_STREAM_NAMESPACE,
@@ -128,7 +130,10 @@ def test_given_state_not_sequential_when_close_partition_then_emit_state(self) -
             _A_STREAM_NAME,
             _A_STREAM_NAMESPACE,
             {
-                "slices": [{"end": 0, "most_recent_cursor_value": 0, "start": 0}, {"end": 30, "start": 12}],
+                "slices": [
+                    {"end": 0, "most_recent_cursor_value": 0, "start": 0},
+                    {"end": 30, "start": 12},
+                ],
                 "state_type": "date-range",
             },
         )