Skip to content

Commit c903420

Browse files
committed
Fix unittest
1 parent 11533d8 commit c903420

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2753,11 +2753,11 @@ def create_simple_retriever(
27532753

27542754
if (
27552755
model.partition_router
2756-
and model.partition_router.type == "SubstreamPartitionRouter" # type: ignore[union-attr] # 'model' is SimpleRetrieverModel
2756+
and isinstance(model.partition_router, SubstreamPartitionRouterModel)
27572757
and not bool(self._connector_state_manager.get_stream_state(name, None))
27582758
and any(
27592759
parent_stream_config.lazy_read_pointer
2760-
for parent_stream_config in model.partition_router.parent_stream_configs # type: ignore[union-attr] # partition_router type guaranteed by a condition earlier
2760+
for parent_stream_config in model.partition_router.parent_stream_configs
27612761
)
27622762
):
27632763
if incremental_sync:

0 commit comments

Comments
 (0)