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
index f33545e3c449..ea6c58e7fd21 100644
--- 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"],
             }