Reverts the json.loads of json objects

hotgluexyz · Dec 18, 2023 · 40eb302 · 40eb302
1 parent 34c1f78
commit 40eb302
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/target_salesforce_v3/sinks.py b/target_salesforce_v3/sinks.py
@@ -34,6 +34,15 @@ def reference_data(self):
 
     def preprocess_record(self, record: dict, context: dict):
 
+        if isinstance(record.get("addresses"), str):
+            record["addresses"] = json.loads(record["addresses"])
+
+        if isinstance(record.get("phone_numbers"), str):
+            record["phone_numbers"] = json.loads(record.get("phone_numbers"))
+
+        if isinstance(record.get("campaigns"), str):
+            record["campaigns"] = json.loads(record.get("campaigns"))
+
         record = self.validate_input(record)
 
         # Handles creation/update of Leads and Contacts