Scheduler: increase the timeout in OpenTelemetry integration tests

Ladicek · Nov 30, 2023 · aa401f1 · aa401f1
1 parent 3b44cde
commit aa401f1
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/...etry-quartz/src/test/java/io/quarkus/it/opentelemetry/quartz/OpenTelemetryQuartzTest.java b/...etry-quartz/src/test/java/io/quarkus/it/opentelemetry/quartz/OpenTelemetryQuartzTest.java
@@ -28,9 +28,9 @@ public class OpenTelemetryQuartzTest {
     @Test
     public void quartzSpanTest() {
         // ensure that scheduled job is called
-        assertCounter("/scheduler/count", 1, Duration.ofSeconds(1));
+        assertCounter("/scheduler/count", 1, Duration.ofSeconds(3));
         // assert programmatically scheduled job is called
-        assertCounter("/scheduler/count/manual", 1, Duration.ofSeconds(1));
+        assertCounter("/scheduler/count/manual", 1, Duration.ofSeconds(3));
         // assert JobDefinition type scheduler
         assertCounter("/scheduler/count/job-definition", 1, Duration.ofSeconds(1));
 
@@ -53,6 +53,7 @@ public void quartzSpanTest() {
 
     private void assertCounter(String counterPath, int expectedCount, Duration timeout) {
         await().atMost(timeout)
+                .pollInterval(Duration.ofMillis(500))
                 .until(() -> {
                     Response response = given().when().get(counterPath);
                     int code = response.statusCode();

diff --git a/...duler/src/test/java/io/quarkus/it/opentelemetry/scheduler/OpenTelemetrySchedulerTest.java b/...duler/src/test/java/io/quarkus/it/opentelemetry/scheduler/OpenTelemetrySchedulerTest.java
@@ -28,9 +28,9 @@ public class OpenTelemetrySchedulerTest {
     @Test
     public void schedulerSpanTest() {
         // ensure that scheduled job is called
-        assertCounter("/scheduler/count", 1, Duration.ofSeconds(1));
+        assertCounter("/scheduler/count", 1, Duration.ofSeconds(3));
         // assert JobDefinition type scheduler
-        assertCounter("/scheduler/count/job-definition", 1, Duration.ofSeconds(1));
+        assertCounter("/scheduler/count/job-definition", 1, Duration.ofSeconds(3));
 
         // ------- SPAN ASSERTS -------
         List<Map<String, Object>> spans = getSpans();
@@ -48,6 +48,7 @@ public void schedulerSpanTest() {
 
     private void assertCounter(String counterPath, int expectedCount, Duration timeout) {
         await().atMost(timeout)
+                .pollInterval(Duration.ofMillis(500))
                 .until(() -> {
                     Response response = given().when().get(counterPath);
                     int code = response.statusCode();