Remove check for removedTaskListener type

elastic · May 28, 2024 · a61e9c9 · a61e9c9
1 parent a928f28
commit a61e9c9
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...c/internalClusterTest/java/org/elasticsearch/action/admin/cluster/node/tasks/TasksIT.java b/...c/internalClusterTest/java/org/elasticsearch/action/admin/cluster/node/tasks/TasksIT.java
@@ -613,9 +613,7 @@ private <T> void waitForCompletionTestCase(boolean storeResult, Function<TaskId,
             @Override
             public void onRemovedTaskListenerRegistered(RemovedTaskListener removedTaskListener) {
                 // Unblock the request only after it started waiting for task completion
-                if (removedTaskListener.toString().startsWith("Waiting for task completion Task{id=" + taskId.getId())) {
-                    client().execute(UNBLOCK_TASK_ACTION, new TestTaskPlugin.UnblockTestTasksRequest());
-                }
+                client().execute(UNBLOCK_TASK_ACTION, new TestTaskPlugin.UnblockTestTasksRequest());
             }
         });
         // Spin up a request to wait for the test task to finish