Rename ID to record_id to accomodate columns named ID

brooklyn-data · Aug 19, 2021 · bf21cb0 · bf21cb0
1 parent 04b38ad
commit bf21cb0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/tap_airtable/airtable_utils/__init__.py b/tap_airtable/airtable_utils/__init__.py
@@ -48,7 +48,7 @@ def match_record_with_keys(cls, schema, records, remove_emojis):
 
                 Relations.save_if_list_of_ids(record.get('fields').get(key), id)
 
-            record_to_dump['id'] = record.get('id')
+            record_to_dump['record_id'] = record.get('id')
 
             records_to_dump.append(record_to_dump)
 

diff --git a/tap_airtable/services/__init__.py b/tap_airtable/services/__init__.py
@@ -25,7 +25,7 @@ def run_discovery(self, args):
                     "name": table_name,
                     "properties": columns}
 
-            columns["id"] = {"type": ["null", "string"], 'key': True}
+            columns["record_id"] = {"type": ["null", "string"], 'key': True}
 
             for field in table["fields"]:
                 if not field["name"] == "Id":
@@ -57,7 +57,7 @@ def run_sync(self, config, properties):
                                                                response.json().get('records'),
                                                                config['remove_emojis'])
 
-                    singer.write_schema(table, schema, 'id')
+                    singer.write_schema(table, schema, 'record_id')
                     singer.write_records(table, records)
 
                     offset = response.json().get("offset")