Add pause in functions IT after context close
- The PulsarFunctionAdministrationIntegrationTests needs a pause after context close to give the stop policy time to run before verifying function status
This commit is contained in:
@@ -162,6 +162,9 @@ class PulsarFunctionAdministrationIntegrationTests {
|
||||
}
|
||||
}
|
||||
|
||||
// Give app context time to close and run the stop policies
|
||||
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);
|
||||
|
||||
Reference in New Issue
Block a user