Fix testCancelViaExpirationOnRemoteResultsWithMinimizeRoundtrips test (#145130) (#145196)

smalyshev · web-flow · commit d176823b737e · 2026-03-30T14:04:58.000-06:00
(cherry picked from commit 6043968) # Conflicts: # muted-tests.yml
diff --git a/x-pack/plugin/async-search/src/internalClusterTest/java/org/elasticsearch/xpack/search/CrossClusterAsyncSearchIT.java b/x-pack/plugin/async-search/src/internalClusterTest/java/org/elasticsearch/xpack/search/CrossClusterAsyncSearchIT.java
@@ -1432,6 +1432,7 @@ public void testCancelViaExpirationOnRemoteResultsWithMinimizeRoundtrips() throw
         request.setKeepOnCompletion(true);
 
         final AsyncSearchResponse response = submitAsyncSearch(request);
+        final long asyncSearchExpirationTimeMillis = response.getExpirationTime();
         try {
             assertNotNull(response.getSearchResponse());
         } finally {
@@ -1468,13 +1469,10 @@ public void testCancelViaExpirationOnRemoteResultsWithMinimizeRoundtrips() throw
             remoteClusterSearchTask.get().cancelled()
         );
 
-        AsyncSearchResponse asyncSearchResponse = getAsyncSearch(response.getId());
-        asyncSearchResponse.decRef();
-
         // wait until the async search has expired (takes one second - keep alive can't be set lower than 1s)
         // don't call get async search as that triggers cancellation of the task - we want to verify that we can cancel it
         // as we get results from a remote cluster
-        assertBusy(() -> assertThat(System.currentTimeMillis(), greaterThanOrEqualTo(asyncSearchResponse.getExpirationTime())));
+        assertBusy(() -> assertThat(System.currentTimeMillis(), greaterThanOrEqualTo(asyncSearchExpirationTimeMillis)));
 
         {
             // check that the tasks are cancelled
