fix logic for unsubscribed

hotgluexyz · Jun 19, 2024 · c85a7cb · c85a7cb
1 parent e4c5c38
commit c85a7cb
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/target_salesforce_v3/sinks.py b/target_salesforce_v3/sinks.py
@@ -45,6 +45,10 @@ def preprocess_record(self, record: dict, context: dict):
 
         if record.get("company") and not record.get("company_name"):
             record["company_name"] = record["company"]
+
+        # if unsubscribed is not get value from unsubscribed_status
+        # assign value to unsubscribed because unsubscribed_status is not a valid model field
+        record["unsubscribed"] = record.get("unsubscribed") if record.get("unsubscribed") is not None else record.get("subscribe_status") == "unsubscribed"
 
         record = self.validate_input(record)
 
@@ -77,9 +81,7 @@ def preprocess_record(self, record: dict, context: dict):
             "Salutation": salutation,
             "Birthdate": birthdate,
             "OwnerId": record.get("owner_id"),
-            "HasOptedOutOfEmail": record.get("unsubscribed")
-            if record.get("unsubscribed") is not None
-            else record.get("subscribe_status") == "unsubscribed",            
+            "HasOptedOutOfEmail": record.get("unsubscribed"),            
             "NumberOfEmployees": record.get("number_of_employees"),
             "Website": record.get("website"),
             "Industry": industry,