Sync History tables

Snowflake syncing of the history tables is failing due to unrecognised data type in the OldValue and NewValue columns. Assigning 'str' type to this fields to resolve the issue.
dext · Oct 10, 2024 · 435d9ed · 435d9ed
1 parent 51f8bbb
commit 435d9ed
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/tap_salesforce/__init__.py b/tap_salesforce/__init__.py
@@ -211,6 +211,9 @@ def do_discover(sf: Salesforce, streams: list[str]):
 
             properties[field_name] = property_schema
 
+            if ((field_name=='OldValue') or (field_name=='NewValue')) and ('History' in sobject_name):
+                properties[field_name] = {'type': ['null', 'string']}
+
         if replication_key:
             mdata = metadata.write(
                 mdata, ('properties', replication_key), 'inclusion', 'automatic')