Merge pull request #309 from VEuPathDB/issue-307

Don't resend reconciliation trigger on update meta exception
VEuPathDB · May 17, 2024 · 5639c59 · 5639c59
2 parents bdb5244 + afe2964
commit 5639c59
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/service/lane/update-meta/src/main/kotlin/vdi/lane/meta/UpdateMetaTriggerHandlerImpl.kt b/service/lane/update-meta/src/main/kotlin/vdi/lane/meta/UpdateMetaTriggerHandlerImpl.kt
@@ -79,12 +79,9 @@ internal class UpdateMetaTriggerHandlerImpl(
   }
 
   private suspend fun updateMeta(dm: DatasetManager, kr: KafkaRouter, msg: EventMessage) {
-    try {
-      updateMeta(dm, msg.userID, msg.datasetID)
-    } finally {
-      if (msg.eventSource != EventSource.FullReconciler)
-        kr.sendReconciliationTrigger(msg.userID, msg.datasetID, msg.eventSource)
-    }
+    updateMeta(dm, msg.userID, msg.datasetID)
+    if (msg.eventSource != EventSource.FullReconciler)
+      kr.sendReconciliationTrigger(msg.userID, msg.datasetID, msg.eventSource)
   }
 
   private suspend fun updateMeta(dm: DatasetManager, userID: UserID, datasetID: DatasetID) {