diff --git a/airbyte/__init__.py b/airbyte/__init__.py index 8e143693..6d6f1f7b 100644 --- a/airbyte/__init__.py +++ b/airbyte/__init__.py @@ -1,8 +1,5 @@ # Copyright (c) 2024 Airbyte, Inc., all rights reserved. -"""PyAirbyte brings Airbyte ELT to every Python developer. - -PyAirbyte brings the power of Airbyte to every Python developer. PyAirbyte provides a set of -utilities to use Airbyte connectors in Python. +"""***PyAirbyte brings the power of Airbyte to every Python developer.*** [![PyPI version](https://badge.fury.io/py/airbyte.svg)](https://badge.fury.io/py/airbyte) [![PyPI - Downloads](https://img.shields.io/pypi/dm/airbyte)](https://pypi.org/project/airbyte/) @@ -121,7 +118,7 @@ ---------------------- -""" +""" # noqa: D415 from __future__ import annotations diff --git a/airbyte/destinations/base.py b/airbyte/destinations/base.py index a61522c1..f879d05a 100644 --- a/airbyte/destinations/base.py +++ b/airbyte/destinations/base.py @@ -293,10 +293,7 @@ def _write_airbyte_message_stream( ) ): if destination_message.type is Type.STATE: - tmp = state_writer.known_stream_names state_writer.write_state(state_message=destination_message.state) - # TODO: DELETEME - assert tmp.issubset(state_writer.known_stream_names) except exc.AirbyteConnectorFailedError as ex: raise exc.AirbyteConnectorWriteError(