Skip to content

Commit f73d79f

Browse files
author
maxime.c
committed
fix incomplete merge
1 parent f290bdf commit f73d79f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2065,7 +2065,7 @@ def create_declarative_stream(
20652065
options["name"] = model.name
20662066
schema_loader = DefaultSchemaLoader(config=config, parameters=options)
20672067

2068-
if isinstance(combined_slicers, PartitionRouter) and not is_parent:
2068+
if isinstance(combined_slicers, PartitionRouter) and not self._emit_connector_builder_messages and not is_parent:
20692069
# We are starting to migrate streams to instantiate directly the DefaultStream instead of instantiating the
20702070
# DeclarativeStream and assembling the DefaultStream from that. The plan is the following:
20712071
# * Streams without partition router nor cursors and streams with only partition router. This is the `isinstance(combined_slicers, PartitionRouter)` condition as the first kind with have a SinglePartitionRouter

0 commit comments

Comments
 (0)