Fix cursor value from record

tolik0 · tolik0 · commit c0bc64538acf · 2025-02-12T17:44:45.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
@@ -363,8 +363,8 @@ def observe(self, record: Record) -> None:
                 "Invalid state as stream slices that are emitted should refer to an existing cursor"
             )
 
-        record_cursor = self._connector_state_converter.parse_value(
-            self._cursor_field.extract_value(record)
+        record_cursor = self._connector_state_converter.output_format(
+            self._connector_state_converter.parse_value(self._cursor_field.extract_value(record))
         )
         self._update_global_cursor(record_cursor)
         if not self._use_global_cursor:

Original file line number	Diff line number	Diff line change
`@@ -363,8 +363,8 @@ def observe(self, record: Record) -> None:`
`363`	`363`	`"Invalid state as stream slices that are emitted should refer to an existing cursor"`
`364`	`364`	`)`
`365`	`365`
`366`		`- record_cursor = self._connector_state_converter.parse_value(`
`367`		`- self._cursor_field.extract_value(record)`
	`366`	`+ record_cursor = self._connector_state_converter.output_format(`
	`367`	`+ self._connector_state_converter.parse_value(self._cursor_field.extract_value(record))`
`368`	`368`	`)`
`369`	`369`	`self._update_global_cursor(record_cursor)`
`370`	`370`	`if not self._use_global_cursor:`