CDK: Fix regression in _checkpoint_state arg (airbytehq#16141)

Signed-off-by: Sergey Chvalyuk <[email protected]>

Author: grubberr

airbyte-cdk/python/CHANGELOG.md

@@ -1,5 +1,8 @@
 # Changelog
 
+## 0.1.81
+- Fix regression in `_checkpoint_state` arg
+
 ## Unreleased
 - Update Airbyte Protocol model to support protocol_version
 

airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py

@@ -228,7 +228,7 @@ def _read_incremental(
         total_records_counter = 0
         if not slices:
             # Safety net to ensure we always emit at least one state message even if there are no slices
-            checkpoint = self._checkpoint_state(stream_instance, stream_instance.state, connector_state)
+            checkpoint = self._checkpoint_state(stream_instance, stream_state, connector_state)
             yield checkpoint
         for _slice in slices:
             logger.debug("Processing stream slice", extra={"slice": _slice})

airbyte-cdk/python/setup.py

@@ -15,7 +15,7 @@
 
 setup(
     name="airbyte-cdk",
-    version="0.1.80",
+    version="0.1.81",
     description="A framework for writing Airbyte Connectors.",
     long_description=README,
     long_description_content_type="text/markdown",
@@ -49,7 +49,7 @@
         "jsonschema~=3.2.0",
         "jsonref~=0.2",
         "pendulum",
-        "pydantic~=1.6",
+        "pydantic~=1.9.2",
         "PyYAML~=5.4",
         "requests",
         "vcrpy",