Fix CrossClusterAsyncQueryStopIT testStopQueryLocal test (elastic#123050) (elastic#123061)

smalyshev · web-flow · commit 245a3a0ebf16 · 2025-02-21T07:01:46.000+11:00
(cherry picked from commit 0852cc0) # Conflicts: # muted-tests.yml # x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterAsyncQueryStopIT.java
diff --git a/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterAsyncQueryStopIT.java b/x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterAsyncQueryStopIT.java
@@ -156,6 +156,7 @@ public void testStopQueryLocal() throws Exception {
                 try (EsqlQueryResponse asyncResponse = getAsyncResponse(client(), asyncExecutionId)) {
                     EsqlExecutionInfo executionInfo = asyncResponse.getExecutionInfo();
                     assertNotNull(executionInfo);
+                    assertThat(executionInfo.isStopped(), is(true));
                 }
             });
             // allow local query to proceed

Original file line number	Diff line number	Diff line change
`@@ -156,6 +156,7 @@ public void testStopQueryLocal() throws Exception {`
`156`	`156`	`try (EsqlQueryResponse asyncResponse = getAsyncResponse(client(), asyncExecutionId)) {`
`157`	`157`	`EsqlExecutionInfo executionInfo = asyncResponse.getExecutionInfo();`
`158`	`158`	`assertNotNull(executionInfo);`
	`159`	`+ assertThat(executionInfo.isStopped(), is(true));`
`159`	`160`	`}`
`160`	`161`	`});`
`161`	`162`	`// allow local query to proceed`