Skip to content

Commit 17430ec

Browse files
fix(cdk): change return to break when partition is None to preserve multi-parent behavior
Co-Authored-By: Daryna Ishchenko <darina.ishchenko17@gmail.com>
1 parent cf50633 commit 17430ec

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,7 @@ def stream_slices(self) -> Iterable[StreamSlice]:
208208
parent_stream.generate_partitions()
209209
):
210210
if partition is None:
211-
return
211+
break
212212
for parent_record, is_last_record_in_slice in iterate_with_last_flag(
213213
partition.read()
214214
):

0 commit comments

Comments
 (0)