Skip to content

Commit

Permalink
fix: Targets to fail gracefully when schema message is missing the `p…
Browse files Browse the repository at this point in the history
…roperties` key (#1287)

Closes #1145
  • Loading branch information
visch authored Dec 20, 2022
1 parent 0c91ad8 commit e12a8fa
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions singer_sdk/target_base.py
Original file line number Diff line number Diff line change
Expand Up @@ -332,6 +332,7 @@ def _process_schema_message(self, message_dict: dict) -> None:
message_dict: The newly received schema message.
"""
self._assert_line_requires(message_dict, requires={"stream", "schema"})
self._assert_line_requires(message_dict["schema"], requires={"properties"})

stream_name = message_dict["stream"]
schema = message_dict["schema"]
Expand Down

0 comments on commit e12a8fa

Please sign in to comment.