From 712bd1084f96be77f38259cf6bad94373b38f692 Mon Sep 17 00:00:00 2001 From: maxi297 Date: Tue, 3 Dec 2024 14:30:28 -0500 Subject: [PATCH] fix code review --- .../sources/declarative/concurrent_declarative_source.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py index b3c7614a2..e47c74ceb 100644 --- a/airbyte_cdk/sources/declarative/concurrent_declarative_source.py +++ b/airbyte_cdk/sources/declarative/concurrent_declarative_source.py @@ -205,14 +205,15 @@ def _group_streams( declarative_stream.name ].get("incremental_sync") - is_without_partition_router_or_cursor = not bool( - incremental_sync_component_definition - ) and not bool(partition_router_component_definition) + partition_router_component_definition = ( name_to_stream_mapping[declarative_stream.name] .get("retriever") .get("partition_router") ) + is_without_partition_router_or_cursor = not bool( + incremental_sync_component_definition + ) and not bool(partition_router_component_definition) is_substream_without_incremental = ( partition_router_component_definition