We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0164a45 commit 80f4976Copy full SHA for 80f4976
1 file changed
airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -1491,7 +1491,9 @@ def create_concurrent_cursor_from_perpartition_cursor(
1491
) or component_definition.get("global_substream_cursor", False)
1492
1493
if not stream_state:
1494
- stream_state = self._connector_state_manager.get_stream_state(stream_name, stream_namespace)
+ stream_state = self._connector_state_manager.get_stream_state(
1495
+ stream_name, stream_namespace
1496
+ )
1497
1498
# Return the concurrent cursor and state converter
1499
return ConcurrentPerPartitionCursor(
0 commit comments