diff --git a/server/src/test/java/org/opensearch/action/search/AbstractSearchAsyncActionTests.java b/server/src/test/java/org/opensearch/action/search/AbstractSearchAsyncActionTests.java index 3a54d539da023..7dcbf213d6c9d 100644 --- a/server/src/test/java/org/opensearch/action/search/AbstractSearchAsyncActionTests.java +++ b/server/src/test/java/org/opensearch/action/search/AbstractSearchAsyncActionTests.java @@ -180,7 +180,7 @@ private AbstractSearchAsyncAction createAction( new GroupShardsIterator<>(Arrays.asList(shards)), timeProvider, ClusterState.EMPTY_STATE, - new SearchTask(123, null, null, null, null, null), + null, results, request.getMaxConcurrentShardRequests(), SearchResponse.Clusters.EMPTY, diff --git a/server/src/test/java/org/opensearch/action/search/CanMatchPreFilterSearchPhaseTests.java b/server/src/test/java/org/opensearch/action/search/CanMatchPreFilterSearchPhaseTests.java index 6307691fcd5c6..1881c705fe6b3 100644 --- a/server/src/test/java/org/opensearch/action/search/CanMatchPreFilterSearchPhaseTests.java +++ b/server/src/test/java/org/opensearch/action/search/CanMatchPreFilterSearchPhaseTests.java @@ -160,7 +160,7 @@ public void sendCanMatch( shardsIter, timeProvider, ClusterState.EMPTY_STATE, - new SearchTask(1, null, null, null, null, null), + null, (iter) -> new SearchPhase("test") { @Override public void run() throws IOException { @@ -258,7 +258,7 @@ public void sendCanMatch( shardsIter, timeProvider, ClusterState.EMPTY_STATE, - new SearchTask(1, null, null, null, null, null), + null, (iter) -> new SearchPhase("test") { @Override public void run() throws IOException { @@ -346,7 +346,7 @@ public void sendCanMatch( shardsIter, timeProvider, ClusterState.EMPTY_STATE, - new SearchTask(1, null, null, null, null, null), + null, (iter) -> { return new WrappingSearchAsyncActionPhase( new AbstractSearchAsyncAction("test", logger, transportService, (cluster, node) -> { @@ -478,7 +478,7 @@ public void sendCanMatch( shardsIter, timeProvider, ClusterState.EMPTY_STATE, - new SearchTask(1, null, null, null, null, null), + null, (iter) -> new SearchPhase("test") { @Override public void run() { @@ -585,7 +585,7 @@ public void sendCanMatch( shardsIter, timeProvider, ClusterState.EMPTY_STATE, - new SearchTask(1, null, null, null, null, null), + null, (iter) -> new SearchPhase("test") { @Override public void run() { @@ -690,7 +690,7 @@ public void sendCanMatch( shardsIter, timeProvider, ClusterState.EMPTY_STATE, - new SearchTask(1, null, null, null, null, null), + null, (iter) -> { AbstractSearchAsyncAction action = new SearchDfsQueryAsyncAction( logger,