improve error logging in state

hotgluexyz · May 24, 2024 · ef716fe · ef716fe
1 parent 1acd30b
commit ef716fe
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/target_salesforce_v3/sinks.py b/target_salesforce_v3/sinks.py
@@ -747,8 +747,7 @@ def preprocess_record(self, record, context):
                         break
 
                 if not object_type:
-                    self.logger.info(f"Record doesn't exist on Salesforce {self.stream_name} was not found on Salesforce.")
-                    return {}
+                    return {"error": f"Object {object_type} doesn't exist on Salesforce"}
 
                 # get record fields
                 try:
@@ -787,7 +786,7 @@ def preprocess_record(self, record, context):
 
     def upsert_record(self, record, context):
         # Not process records if target hit API rate limits
-        if record.get("error") and self._target.hit_rate_limit:
+        if record.get("error"):
             return None, False, record
         if record:
             state_updates = dict()