diff --git a/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py b/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py
index 856774e0..e67f1f9e 100644
--- a/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py
+++ b/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py
@@ -112,7 +112,9 @@ def stream_slices(self) -> Iterable[StreamSlice]:
         * Yield the last slice. At that point, once there are as many slices yielded as closes, the global slice will be closed too
         """
         slice_generator = (
-            StreamSlice(partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields)
+            StreamSlice(
+                partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields
+            )
             for partition in self._partition_router.stream_slices()
             for cursor_slice in self._stream_cursor.stream_slices()
         )
@@ -128,7 +130,9 @@ def stream_slices(self) -> Iterable[StreamSlice]:
 
     def generate_slices_from_partition(self, partition: StreamSlice) -> Iterable[StreamSlice]:
         slice_generator = (
-            StreamSlice(partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields)
+            StreamSlice(
+                partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields
+            )
             for cursor_slice in self._stream_cursor.stream_slices()
         )