fix: deleted records handling

messagebird · Sep 12, 2024 · cefd05c · cefd05c
1 parent d34b521
commit cefd05c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/airbyte-integrations/connectors/source-shopify/source_shopify/streams/base_streams.py b/airbyte-integrations/connectors/source-shopify/source_shopify/streams/base_streams.py
@@ -148,8 +148,8 @@ def produce_deleted_records_from_events(self, delete_events: Iterable[Mapping[st
                 "id": event["subject_id"],
                 self.cursor_field: event["created_at"],
                 "updated_at": event["created_at"],
-                "deleted_message": event["message"],
-                "deleted_description": event["description"],
+                "deleted_message": event.get("message", None),
+                "deleted_description": event.get("description", None),
                 "shop_url": event["shop_url"],
             }
 

diff --git a/python b/python
@@ -0,0 +1 @@
+/usr/local/bin/python3.10