Fix flaky PulsarFunctionAdministrationIntegrationTests

Pause after context close to give stop policies time to execute
This commit is contained in:
Chris Bono
2023-02-22 12:44:13 -06:00
parent fa7a2fa818
commit dad0961eac

View File

@@ -162,6 +162,9 @@ class PulsarFunctionAdministrationIntegrationTests {
}
}
// Give functions time to invoke stop policy after context close
Thread.sleep(10000);
// Stop policy runs after context close - verify source are in expected state
try (PulsarAdmin admin = getAdmin()) {
assertSourceExistsWithStatus("rabbit-test-source-none", true, admin);