Skip to content

Commit 5f8cd39

Browse files
authored
[7.16] Fix Watcher testWatcherWithApiKey (#82136) (#82230)
1 parent 8684b76 commit 5f8cd39

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

x-pack/qa/full-cluster-restart/src/test/java/org/elasticsearch/xpack/restart/FullClusterRestartIT.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,6 @@ public void testWatcher() throws Exception {
233233
}
234234

235235
@SuppressWarnings("unchecked")
236-
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/77026")
237236
public void testWatcherWithApiKey() throws Exception {
238237
assumeTrue("API key is available since 6.7.0", getOldClusterVersion().onOrAfter(Version.V_6_7_0));
239238
if (isRunningAgainstOldCluster()) {
@@ -259,7 +258,7 @@ public void testWatcherWithApiKey() throws Exception {
259258
final Map<String, Object> getWatchStatusResponse = entityAsMap(client().performRequest(getRequest));
260259
final Map<String, Object> status = (Map<String, Object>) getWatchStatusResponse.get("status");
261260
assertEquals("executed", status.get("execution_state"));
262-
});
261+
}, 30, TimeUnit.SECONDS);
263262

264263
} else {
265264
logger.info("testing against {}", getOldClusterVersion());
@@ -299,7 +298,7 @@ public void testWatcherWithApiKey() throws Exception {
299298
versionIncreased.get() && executed.get(),
300299
is(true)
301300
);
302-
});
301+
}, 30, TimeUnit.SECONDS);
303302
} finally {
304303
stopWatcher();
305304
}

0 commit comments

Comments
 (0)