Add comments for state format

tolik0 · tolik0 · commit d4d52b962939 · 2025-01-22T17:57:55.000+02:00
diff --git a/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py b/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
@@ -51,6 +51,8 @@ class ConcurrentPerPartitionCursor(Cursor):
 
     - **Global Cursor Fallback**
       New partitions use global state as the initial state to progress the state for deleted or new partitions. The history data added after the initial sync will be missing.
+
+    CurrentPerPartitionCursor expects the state of the ConcurrentCursor to follow the format {cursor_field: cursor_value}.
     """
 
     DEFAULT_MAX_PARTITIONS_NUMBER = 10000
diff --git a/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py b/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -937,7 +937,7 @@ def create_concurrent_cursor_from_datetime_based_cursor(
         connector_state_converter = CustomFormatConcurrentStreamStateConverter(
             datetime_format=datetime_format,
             input_datetime_formats=datetime_based_cursor_model.cursor_datetime_formats,
-            is_sequential_state=True,
+            is_sequential_state=True,  # ConcurrentPerPartitionCursor only works with sequential state
             cursor_granularity=cursor_granularity,
         )
 

Original file line number	Diff line number	Diff line change
`@@ -937,7 +937,7 @@ def create_concurrent_cursor_from_datetime_based_cursor(`
`937`	`937`	`connector_state_converter = CustomFormatConcurrentStreamStateConverter(`
`938`	`938`	`datetime_format=datetime_format,`
`939`	`939`	`input_datetime_formats=datetime_based_cursor_model.cursor_datetime_formats,`
`940`		`- is_sequential_state=True,`
	`940`	`+ is_sequential_state=True, # ConcurrentPerPartitionCursor only works with sequential state`
`941`	`941`	`cursor_granularity=cursor_granularity,`
`942`	`942`	`)`
`943`	`943`