doc-level monitor fan-out approach

Signed-off-by: Subhobrata Dey <[email protected]>
eirsep · Apr 2, 2024 · e4b7310 · e4b7310
1 parent 22459a7
commit e4b7310
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt b/alerting/src/main/kotlin/org/opensearch/alerting/DocumentLevelMonitorRunner.kt
@@ -240,7 +240,10 @@ class DocumentLevelMonitorRunner : MonitorRunner() {
                                 }
 
                                 override fun onFailure(e: Exception) {
-                                    cont.resumeWithException(e)
+                                    if (e.cause is Exception)
+                                        cont.resumeWithException(e.cause as Exception)
+                                    else
+                                        cont.resumeWithException(e)
                                 }
                             },
                             nodeShardAssignments.size