Skip to content

Commit 3c94fb3

Browse files
author
maxi297
committed
Properly setup global substream cursor based on manifest
1 parent 24cbc51 commit 3c94fb3

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
@@ -1439,7 +1439,7 @@ def create_concurrent_cursor_from_perpartition_cursor(
14391439
stream_state = self.apply_stream_state_migrations(stream_state_migrations, stream_state)
14401440

14411441
# Per-partition state doesn't make sense for GroupingPartitionRouter, so force the global state
1442-
use_global_cursor = isinstance(partition_router, GroupingPartitionRouter)
1442+
use_global_cursor = isinstance(partition_router, GroupingPartitionRouter) or component_definition.get("global_substream_cursor", False)
14431443

14441444
# Return the concurrent cursor and state converter
14451445
return ConcurrentPerPartitionCursor(

0 commit comments

Comments
 (0)