diff --git a/server/src/internalClusterTest/java/org/elasticsearch/action/admin/cluster/node/tasks/TasksIT.java b/server/src/internalClusterTest/java/org/elasticsearch/action/admin/cluster/node/tasks/TasksIT.java index 404ad939b8ad5..9ceeec2b129fb 100644 --- a/server/src/internalClusterTest/java/org/elasticsearch/action/admin/cluster/node/tasks/TasksIT.java +++ b/server/src/internalClusterTest/java/org/elasticsearch/action/admin/cluster/node/tasks/TasksIT.java @@ -526,7 +526,7 @@ public void testTasksUnblocking() throws Exception { ) ); - new TestTaskPlugin.UnblockTestTasksRequestBuilder(client(), UNBLOCK_TASK_ACTION).get(); + client().execute(UNBLOCK_TASK_ACTION, new TestTaskPlugin.UnblockTestTasksRequest()).get(); future.get(); assertBusy( @@ -611,7 +611,7 @@ public void onTaskUnregistered(Task task) { waitForWaitingToStart.await(); } finally { // Unblock the request so the wait for completion request can finish - new TestTaskPlugin.UnblockTestTasksRequestBuilder(client(), UNBLOCK_TASK_ACTION).get(); + client().execute(UNBLOCK_TASK_ACTION, new TestTaskPlugin.UnblockTestTasksRequest()).get(); } // Now that the task is unblocked the list response will come back @@ -669,7 +669,7 @@ private void waitForTimeoutTestCase(Function { - - protected UnblockTestTasksRequestBuilder(ElasticsearchClient client, ActionType action) { - super(client, action, new UnblockTestTasksRequest()); - } - } - private static class OriginAssertingInterceptor implements TransportInterceptor { private final ThreadContext threadContext;