HGI-6464: export failing on datetime serialization issues

hotgluexyz · Sep 9, 2024 · fc70ccb · fc70ccb
1 parent 9f586fb
commit fc70ccb
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/.DS_Store b/.DS_Store
diff --git a/target_salesforce_v3/sinks.py b/target_salesforce_v3/sinks.py
@@ -923,6 +923,11 @@ def preprocess_record(self, record, context):
             if self.config.get("only_upsert_empty_fields"):
                 record = {k:v for k,v in record.items() if not existing_record.get(k)}
             record["Id"] = existing_record["Id"]
+
+        # convert any datetimes to string to avoid json encoding errors
+        for key in record:
+            if isinstance(record.get(key), datetime):
+                record[key] = record[key].isoformat()
         return record
 
     def upsert_record(self, record, context):