We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3982de0 commit 0d0d6fbCopy full SHA for 0d0d6fb
1 file changed
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
@@ -1251,6 +1251,14 @@ protected void getFunctionStatsEmpty(String functionName) throws Exception {
1251
}
1252
1253
private void getFunctionStats(String functionName, int numMessages) throws Exception {
1254
+ Awaitility.await()
1255
+ .pollInterval(Duration.ofSeconds(1))
1256
+ .atMost(Duration.ofSeconds(15))
1257
+ .ignoreExceptions()
1258
+ .untilAsserted(() -> doGetFunctionStats(functionName, numMessages));
1259
+ }
1260
+
1261
+ private void doGetFunctionStats(String functionName, int numMessages) throws Exception {
1262
ContainerExecResult result = pulsarCluster.getAnyWorker().execCmd(
1263
PulsarCluster.ADMIN_SCRIPT,
1264
"functions",
0 commit comments