Skip to content

Commit 0164a45

Browse files
committed
add check for state empty to get ir from state manager
1 parent 9ad1bc0 commit 0164a45

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1490,6 +1490,9 @@ def create_concurrent_cursor_from_perpartition_cursor(
14901490
partition_router, GroupingPartitionRouter
14911491
) or component_definition.get("global_substream_cursor", False)
14921492

1493+
if not stream_state:
1494+
stream_state = self._connector_state_manager.get_stream_state(stream_name, stream_namespace)
1495+
14931496
# Return the concurrent cursor and state converter
14941497
return ConcurrentPerPartitionCursor(
14951498
cursor_factory=cursor_factory,

0 commit comments

Comments
 (0)