Adjusted assertion for watcher rolling upgrade test. (#52463)

Relates to #33185

Author: martijnvg

x-pack/qa/rolling-upgrade/src/test/java/org/elasticsearch/upgrades/UpgradeClusterClientYamlTestSuiteIT.java

@@ -23,9 +23,10 @@
 import java.util.Base64;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 import static org.hamcrest.Matchers.equalTo;
-
+import static org.hamcrest.Matchers.greaterThanOrEqualTo;
 
 @TimeoutSuite(millis = 5 * TimeUnits.MINUTE) // to account for slow as hell VMs
 public class UpgradeClusterClientYamlTestSuiteIT extends ESClientYamlSuiteTestCase {
@@ -46,12 +47,12 @@ public void waitForWatcher() throws Exception {
             Response response = client().performRequest(new Request("GET", "_watcher/stats"));
             Map<String, Object> responseBody = entityAsMap(response);
             List<?> stats = (List<?>) responseBody.get("stats");
-            assertThat(stats.size(), equalTo(3));
+            assertThat(stats.size(), greaterThanOrEqualTo(3));
             for (Object stat : stats) {
                 Map<?, ?> statAsMap = (Map<?, ?>) stat;
                 assertThat(statAsMap.get("watcher_state"), equalTo("started"));
             }
-        });
+        }, 1, TimeUnit.MINUTES);
     }
 
     @Override