Skip to content

Commit

Permalink
fix: handle control message type (#28)
Browse files Browse the repository at this point in the history
Closes #27

This is not a sustainable refactor to solve this, it just patches the
current issue I ran into.
  • Loading branch information
pnadolny13 authored Jan 16, 2025
1 parent e573ee8 commit bb7999a
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions tap_airbyte/tap.py
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,7 @@ class AirbyteMessage(str, Enum):
CATALOG = "CATALOG"
SPEC = "SPEC"
CONNECTION_STATUS = "CONNECTION_STATUS"
CONTROL = "CONTROL"


# These translate between Singer's replication method and Airbyte's sync mode
Expand Down Expand Up @@ -862,6 +863,8 @@ def sync_all(self) -> None:

with STDOUT_LOCK:
singer.write_message(singer.StateMessage(self.airbyte_state))
elif airbyte_message["type"] == AirbyteMessage.CONTROL:
pass
else:
self.logger.warning("Unhandled message: %s", airbyte_message)
# Daemon threads will be terminated when the main thread exits,
Expand Down

0 comments on commit bb7999a

Please sign in to comment.