From f1748ad107406f6e4a67ec0053f9329b85ab41e7 Mon Sep 17 00:00:00 2001 From: AWSHurneyt Date: Mon, 5 Feb 2024 02:03:30 -0800 Subject: [PATCH] Adding wait. Signed-off-by: AWSHurneyt --- .../src/main/kotlin/org/opensearch/alerting/InputService.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt b/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt index 855907bbe..d3f8b3e19 100644 --- a/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt +++ b/alerting/src/main/kotlin/org/opensearch/alerting/InputService.kt @@ -141,8 +141,8 @@ class InputService( } } // todo hurneyt delete? -// while (responseMap.size < input.clusters.size) { -// } + while (responseMap.size < input.clusters.size) { + } results += responseMap } else { val response = executeTransportAction(input, client)