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 @@ -115,7 +115,9 @@ def stream_slices(self) -> Iterable[StreamSlice]:
115
115
* Yield the last slice. At that point, once there are as many slices yielded as closes, the global slice will be closed too
116
116
"""
117
117
slice_generator = (
118
- StreamSlice (partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields )
118
+ StreamSlice (
119
+ partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields
120
+ )
119
121
for partition in self ._partition_router .stream_slices ()
120
122
for cursor_slice in self ._stream_cursor .stream_slices ()
121
123
)
@@ -131,7 +133,9 @@ def stream_slices(self) -> Iterable[StreamSlice]:
131
133
132
134
def generate_slices_from_partition (self , partition : StreamSlice ) -> Iterable [StreamSlice ]:
133
135
slice_generator = (
134
- StreamSlice (partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields )
136
+ StreamSlice (
137
+ partition = partition , cursor_slice = cursor_slice , extra_fields = partition .extra_fields
138
+ )
135
139
for cursor_slice in self ._stream_cursor .stream_slices ()
136
140
)
137
141
You can’t perform that action at this time.
0 commit comments