From ad0d49b0c660c8253e09ecd7dd95290d4d25235b Mon Sep 17 00:00:00 2001 From: Anatolii Yatsuk Date: Thu, 6 Jun 2024 20:10:49 +0300 Subject: [PATCH] Update comment --- .../declarative/partition_routers/substream_partition_router.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airbyte-cdk/python/airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py b/airbyte-cdk/python/airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py index f7bedf403e77..16afc42b26a6 100644 --- a/airbyte-cdk/python/airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py +++ b/airbyte-cdk/python/airbyte_cdk/sources/declarative/partition_routers/substream_partition_router.py @@ -139,7 +139,7 @@ def stream_slices(self) -> Iterable[StreamSlice]: # we need to read all records for slice to update the parent stream cursor stream_slices_for_parent = [] - # only stream_slice param is used in the declarative stream + # only stream_slice param is used in the declarative stream, stream state is set in PerPartitionCursor set_initial_state for parent_record in parent_stream.read_records( sync_mode=SyncMode.full_refresh, cursor_field=None, stream_slice=parent_stream_slice, stream_state=None ):