File tree 1 file changed +6
-2
lines changed
airbyte_cdk/sources/declarative/incremental
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]:
112
112
* Yield the last slice. At that point, once there are as many slices yielded as closes, the global slice will be closed too
113
113
"""
114
114
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
+ )
116
118
for partition in self ._partition_router .stream_slices ()
117
119
for cursor_slice in self ._stream_cursor .stream_slices ()
118
120
)
@@ -128,7 +130,9 @@ def stream_slices(self) -> Iterable[StreamSlice]:
128
130
129
131
def generate_slices_from_partition (self , partition : StreamSlice ) -> Iterable [StreamSlice ]:
130
132
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
+ )
132
136
for cursor_slice in self ._stream_cursor .stream_slices ()
133
137
)
134
138
You can’t perform that action at this time.
0 commit comments