We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 035264c commit 8158f0dCopy full SHA for 8158f0d
airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -3865,7 +3865,9 @@ def _instantiate_parent_stream_state_manager(
3865
3866
if not parent_state and not isinstance(parent_state, dict):
3867
cursor_values = child_state.values()
3868
- if cursor_values:
+ if cursor_values and len(cursor_values) == 1:
3869
+ # We assume the child state is a pair `{<cursor_field>: <cursor_value>}` and we will use the
3870
+ # cursor value as a parent state.
3871
incremental_sync_model: Union[
3872
DatetimeBasedCursorModel,
3873
IncrementingCountCursorModel,
0 commit comments