Use normalized record for upsert

altitudenetworks · Mar 31, 2020 · df16520 · df16520
1 parent 0500c2d
commit df16520
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/dynamo_query/dynamo_table.py b/dynamo_query/dynamo_table.py
@@ -538,9 +538,9 @@ def batch_upsert(
                     "dt_modified": now_str,
                 },
             )
-            self.normalize_record(new_record)
-            self.validate_record_attributes(new_record)
-            update_data_table.add_record(new_record)
+            normalized_record = self.normalize_record(new_record)
+            self.validate_record_attributes(normalized_record)
+            update_data_table.add_record(normalized_record)
 
         results: DataTable[DynamoRecord] = DynamoQuery.build_batch_update_item(
             logger=self._logger,