Skip to content

Commit

Permalink
Fix: Misc cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
aaronsteers committed Jul 30, 2024
1 parent 1bcb440 commit 92a0b7e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 8 deletions.
7 changes: 2 additions & 5 deletions airbyte/__init__.py
Original file line number Diff line number Diff line change
@@ -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/)
Expand Down Expand Up @@ -121,7 +118,7 @@
----------------------
"""
""" # noqa: D415

from __future__ import annotations

Expand Down
3 changes: 0 additions & 3 deletions airbyte/destinations/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit 92a0b7e

Please sign in to comment.