Execute post submission async tasks after transaction commit

Signed-off-by: Kipchirchir Sigei <[email protected]>
onaio · Sep 1, 2023 · cc2e049 · cc2e049
1 parent e5bdec9
commit cc2e049
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/onadata/apps/logger/models/instance.py b/onadata/apps/logger/models/instance.py
@@ -829,9 +829,19 @@ def post_save_submission(sender, instance=None, created=False, **kwargs):
         _update_xform_submission_count_delete(instance)
 
     if ASYNC_POST_SUBMISSION_PROCESSING_ENABLED:
-        update_xform_submission_count_async.apply_async(args=[instance.pk, created])
-        save_full_json_async.apply_async(args=[instance.pk, created])
-        update_project_date_modified_async.apply_async(args=[instance.pk, created])
+        transaction.on_commit(
+            lambda: update_xform_submission_count_async.apply_async(
+                args=[instance.pk, created]
+            )
+        )
+        transaction.on_commit(
+            lambda: save_full_json_async.apply_async(args=[instance.pk, created])
+        )
+        transaction.on_commit(
+            lambda: update_project_date_modified_async.apply_async(
+                args=[instance.pk, created]
+            )
+        )
 
     else:
         update_xform_submission_count(instance.pk, created)