From 6b743c9796b7fcb52613a2a37573b0ec05aa01b5 Mon Sep 17 00:00:00 2001 From: jsinovassin Date: Tue, 29 Oct 2024 14:24:00 +0100 Subject: [PATCH] UNOMI-861: fix task check in migration" --- .../apache/unomi/shell/migration/utils/MigrationUtils.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/tools/shell-commands/src/main/java/org/apache/unomi/shell/migration/utils/MigrationUtils.java b/tools/shell-commands/src/main/java/org/apache/unomi/shell/migration/utils/MigrationUtils.java index 69521c729..e08cbb733 100644 --- a/tools/shell-commands/src/main/java/org/apache/unomi/shell/migration/utils/MigrationUtils.java +++ b/tools/shell-commands/src/main/java/org/apache/unomi/shell/migration/utils/MigrationUtils.java @@ -335,7 +335,7 @@ public static void deleteByQuery(CloseableHttpClient httpClient, String esAddres public static void waitForTaskToFinish(CloseableHttpClient httpClient, String esAddress, String taskId, MigrationContext migrationContext) throws IOException { while (true) { final JSONObject status = new JSONObject( - HttpUtils.executeGetRequest(httpClient, esAddress + "/_tasks/" + taskId + "?wait_for_completion=true&timeout=15s", + HttpUtils.executeGetRequest(httpClient, esAddress + "/_tasks/" + taskId, null)); if (status.has("completed") && status.getBoolean("completed")) { if (migrationContext != null) { @@ -354,6 +354,11 @@ public static void waitForTaskToFinish(CloseableHttpClient httpClient, String es } else { LOGGER.info("Waiting for Task {} to complete", taskId); } + try { + Thread.sleep(5000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } } }