don't resend reconciliation trigger on update meta exception

VEuPathDB · May 16, 2024 · afe2964 · afe2964
1 parent 2697ae1
commit afe2964
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) {