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 f33545e3c4493..ea6c58e7fd21a 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"], } diff --git a/python b/python new file mode 120000 index 0000000000000..bac108717b725 --- /dev/null +++ b/python @@ -0,0 +1 @@ +/usr/local/bin/python3.10 \ No newline at end of file