Summary
Encountering a KeyError ‘message’ when syncing orders from Shopify using the Airbyte Shopify connector. The error occurs in the source_shopify connector code while trying to read records.
Question
Hello, I’m encountering a KeyError: 'message' when syncing orders from Shopify using the Airbyte Shopify connector. source > Encountered an exception while reading stream orders
248
Traceback (most recent call last):
249
File “/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py”, line 119, in read
250
yield from self._read_stream(
251
File “/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py”, line 194, in _read_stream
252
for record in record_iterator:
253
File “/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py”, line 250, in _read_incremental
254
for message_counter, record_data_or_message in enumerate(records, start=1):
255
File “/airbyte/integration_code/source_shopify/source.py”, line 298, in read_records
256
yield from self.deleted_events.read_records(stream_state=stream_state, **kwargs)
257
File “/airbyte/integration_code/source_shopify/source.py”, line 160, in read_records
258
yield from self.produce_deleted_records_from_events(delete_events)
259
File “/airbyte/integration_code/source_shopify/source.py”, line 153, in produce_deleted_records_from_events
260
“deleted_message”: event[“message”],
261
KeyError: ‘message’
262
2024-09-13 15:41:59 source > Marking stream orders as STOPPED
263
2024-09-13 15:41:59 source > Finished syncing orders
This topic has been created from a Slack thread to give it more visibility.
It will be on Read-Only mode here. Click here if you want
to access the original thread.