Fix testCancelViaExpirationOnRemoteResultsWithMinimizeRoundtrips test (#145130)

smalyshev · web-flow · commit 604396800e35 · 2026-03-30T07:40:38.000+02:00
diff --git a/muted-tests.yml b/muted-tests.yml
@@ -234,9 +234,6 @@ tests:
 - class: org.elasticsearch.packaging.test.DebMetadataTests
   method: test05CheckLintian
   issue: https://github.com/elastic/elasticsearch/issues/142819
-- class: org.elasticsearch.xpack.search.CrossClusterAsyncSearchIT
-  method: testCancelViaExpirationOnRemoteResultsWithMinimizeRoundtrips
-  issue: https://github.com/elastic/elasticsearch/issues/143407
 - class: org.elasticsearch.xpack.security.support.MetadataFlattenedMigrationIntegTests
   method: testMigrationWithConcurrentUpdates
   issue: https://github.com/elastic/elasticsearch/issues/143674
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
@@ -1747,6 +1747,7 @@ public void testCancelViaExpirationOnRemoteResultsWithMinimizeRoundtrips() throw
         request.setKeepOnCompletion(true);
 
         final AsyncSearchResponse response = submitAsyncSearch(request);
+        final long asyncSearchExpirationTimeMillis = response.getExpirationTime();
         try {
             assertNotNull(response.getSearchResponse());
         } finally {
@@ -1783,13 +1784,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
