fix code review

airbytehq · Dec 3, 2024 · 712bd10 · 712bd10
1 parent 1e94817
commit 712bd10
Showing 1 changed file with 4 additions and 3 deletions.
diff --git 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