diff --git a/tap_typeform/streams.py b/tap_typeform/streams.py index 199b020..8a46694 100644 --- a/tap_typeform/streams.py +++ b/tap_typeform/streams.py @@ -174,10 +174,10 @@ def sync_form(atx, form_id, start_date, end_date): answer_value = answer[data_type] answers_data_rows.append({ - "landing_id": row['landing_id'], - "question_id": answer['field']['id'], - "type": answer['field']['type'], - "ref": answer['field']['ref'], + "landing_id": row.get('landing_id'), + "question_id": answer.get('field',{}).get('id'), + "type": answer.get('field',{}).get('type'), + "ref": answer.get('field',{}).get('ref'), "data_type": data_type, "answer": answer_value })