Merge pull request #472 from NCATSTranslator/fixNormalizerSaveState

moved save of sync responses to after pre-processing
NCATSTranslator · Aug 10, 2023 · f7bcdad · f7bcdad
2 parents 737e2ba + 8aaeca5
commit f7bcdad
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tr_sys/tr_ars/tasks.py b/tr_sys/tr_ars/tasks.py
@@ -117,14 +117,14 @@ def send_message(actor_dict, mesg_dict, timeout=300):
                         #message_to_merge = utils.get_safe(rdata,"message")
                         message_to_merge=rdata
                         agent_name = str(mesg.actor.agent.name)
+
+                        utils.pre_merge_process(message_to_merge,mesg_dict['pk'], agent_name)
                         mesg.code = status_code
                         mesg.status = status
                         mesg.data = rdata
                         mesg.url = url
                         mesg.save()
                         logger.debug('+++ message saved: %s' % (mesg.pk))
-                        utils.pre_merge_process(message_to_merge,mesg_dict['pk'], agent_name)
-
                         if agent_name.startswith('ara-'):
                             new_merged = utils.merge_received(parent_pk,message_to_merge['message'], agent_name)
                             utils.post_process(new_merged.data,new_merged.pk, agent_name)