From dad0961eac514ecdf10cb634e37dc1817ecdded2 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Wed, 22 Feb 2023 12:44:13 -0600 Subject: [PATCH] Fix flaky PulsarFunctionAdministrationIntegrationTests Pause after context close to give stop policies time to execute --- .../PulsarFunctionAdministrationIntegrationTests.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java b/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java index 9d0e01fe..a2f12946 100644 --- a/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java +++ b/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java @@ -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);