Attempt to fix elastic#80089

craigtaverner · Apr 26, 2024 · 96f71bb · 96f71bb
1 parent 9a7cd05
commit 96f71bb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ugin/sql/qa/server/src/main/java/org/elasticsearch/xpack/sql/qa/rest/RestSqlTestCase.java b/...ugin/sql/qa/server/src/main/java/org/elasticsearch/xpack/sql/qa/rest/RestSqlTestCase.java
@@ -107,7 +107,8 @@ protected String indexPattern(String pattern) {
     }
 
     @After
-    private void cleanup() throws IOException {
+    public void cleanup() throws Exception {
+        waitForPendingTasks(adminClient(), taskName -> taskName.startsWith("indices:data/read/sql/async/get"));
         try {
             deleteTestIndex();
         } catch (ResponseException e) {
@@ -1531,7 +1532,6 @@ public void testAsyncTextWait() throws IOException {
         }
     }
 
-    @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/80089")
     public void testAsyncTextPaginated() throws IOException, InterruptedException {
         final Map<String, String> acceptMap = Map.of("txt", "text/plain", "csv", "text/csv", "tsv", "text/tab-separated-values");
         final int fetchSize = randomIntBetween(1, 10);