🐛 CDK: Fix logging of initial state value (#4795)

* Update abstract_source.py * bump * CHANGELOG.md Co-authored-by: Eugene Kulak <kulak.eugene@gmail.com>
airbytehq · Jul 18, 2021 · d753dfc · d753dfc
1 parent a8308c4
commit d753dfc
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/airbyte-cdk/python/CHANGELOG.md b/airbyte-cdk/python/CHANGELOG.md
@@ -1,5 +1,9 @@
 # Changelog
 
+## 0.1.6
+Add initial destination abstraction.
+Fix logging of the initial state.
+
 ## 0.1.5
 Allow specifying keyword arguments to be sent on a request made by an HTTP stream: https://github.com/airbytehq/airbyte/pull/4493
 

diff --git a/airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py b/airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py
@@ -149,7 +149,7 @@ def _read_incremental(
         stream_name = configured_stream.stream.name
         stream_state = connector_state.get(stream_name, {})
         if stream_state:
-            logger.info(f"Setting state of {stream_name} stream to {stream_state.get(stream_name)}")
+            logger.info(f"Setting state of {stream_name} stream to {stream_state}")
 
         checkpoint_interval = stream_instance.state_checkpoint_interval
         slices = stream_instance.stream_slices(

diff --git a/airbyte-cdk/python/setup.py b/airbyte-cdk/python/setup.py
@@ -35,7 +35,7 @@
 
 setup(
     name="airbyte-cdk",
-    version="0.1.6-rc1",
+    version="0.1.6",
     description="A framework for writing Airbyte Connectors.",
     long_description=README,
     long_description_content_type="text/markdown",