From d753dfce493ec4c28237fb0f1a9cba611f90f215 Mon Sep 17 00:00:00 2001 From: Eugene Kulak Date: Sun, 18 Jul 2021 14:34:03 +0300 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20CDK:=20Fix=20logging=20of=20init?= =?UTF-8?q?ial=20state=20value=20(#4795)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * Update abstract_source.py * bump * CHANGELOG.md Co-authored-by: Eugene Kulak --- airbyte-cdk/python/CHANGELOG.md | 4 ++++ airbyte-cdk/python/airbyte_cdk/sources/abstract_source.py | 2 +- airbyte-cdk/python/setup.py | 2 +- 3 files changed, 6 insertions(+), 2 deletions(-) diff --git a/airbyte-cdk/python/CHANGELOG.md b/airbyte-cdk/python/CHANGELOG.md index fda59b2cd649..d2750f3d24f3 100644 --- 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 index 7ca61564fa36..a2f3b1c5adfb 100644 --- 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 index baae77fc65e7..bd7039972769 100644 --- 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",