File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
airbyte_cdk/sources/declarative/incremental Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -112,7 +112,9 @@ def stream_slices(self) -> Iterable[StreamSlice]:
112112 * Yield the last slice. At that point, once there are as many slices yielded as closes, the global slice will be closed too
113113 """
114114 slice_generator = (
115- StreamSlice (partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields )
115+ StreamSlice (
116+ partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields
117+ )
116118 for partition in self ._partition_router .stream_slices ()
117119 for cursor_slice in self ._stream_cursor .stream_slices ()
118120 )
@@ -128,7 +130,9 @@ def stream_slices(self) -> Iterable[StreamSlice]:
128130
129131 def generate_slices_from_partition (self , partition : StreamSlice ) -> Iterable [StreamSlice ]:
130132 slice_generator = (
131- StreamSlice (partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields )
133+ StreamSlice (
134+ partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields
135+ )
132136 for cursor_slice in self ._stream_cursor .stream_slices ()
133137 )
134138
You can’t perform that action at this time.
0 commit comments