Delete unused method

airbytehq · Jan 30, 2025 · be80c9f · be80c9f
1 parent 25b6980
commit be80c9f
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py b/airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
@@ -396,10 +396,5 @@ def _get_cursor(self, record: Record) -> ConcurrentCursor:
         cursor = self._cursor_per_partition[partition_key]
         return cursor
 
-    def _extract_cursor_value_from_state(self, state: StreamState) -> Any:
-        return self._connector_state_converter.parse_value(
-            state[self.cursor_field.cursor_field_key]
-        )
-
     def limit_reached(self) -> bool:
         return self._over_limit > self.DEFAULT_MAX_PARTITIONS_NUMBER