Restore test-timeouts

kagkarlsson · May 23, 2020 · 81e9120 · 81e9120
1 parent c46e4ae
commit 81e9120
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/ClusterTest.java b/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/ClusterTest.java
@@ -38,7 +38,7 @@ public class ClusterTest {
 
     @Test
     public void test_concurrency() throws InterruptedException {
-        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(20), () -> {
+        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(10), () -> {
 
             final List<String> ids = IntStream.range(1, 1001).mapToObj(String::valueOf).collect(toList());
 
@@ -75,7 +75,7 @@ public void test_concurrency() throws InterruptedException {
 
     @Test
     public void test_concurrency_recurring() throws InterruptedException {
-        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(20), () -> {
+        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(10), () -> {
 
             final RecurringTask<Void> task1 = Tasks.recurring("task1", Schedules.fixedDelay(Duration.ofMillis(0)))
                 .execute((taskInstance, executionContext) -> {

diff --git a/...cheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/DeadExecutionTest.java b/...cheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/DeadExecutionTest.java
@@ -30,7 +30,7 @@ public class DeadExecutionTest {
 
     @Test
     public void test_dead_execution() {
-        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(20), () -> {
+        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(5), () -> {
             CustomTask<Void> customTask = Tasks.custom("custom-a", Void.class)
                 .execute((taskInstance, executionContext) -> new CompletionHandler<Void>() {
                     @Override

diff --git a/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/ExecutorPoolTest.java b/db-scheduler/src/test/java/com/github/kagkarlsson/scheduler/functional/ExecutorPoolTest.java
@@ -59,7 +59,7 @@ public void test_execute_until_none_left_high_volume() {
 
 
     private void testExecuteUntilNoneLeft(int pollingLimit, int threads, int executionsToRun) {
-        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(20), () -> {
+        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(5), () -> {
 
             Instant now = Instant.now();
             OneTimeTask<Void> task = TestTasks.oneTime("onetime-a", Void.class, TestTasks.DO_NOTHING);

diff --git a/...ler/src/test/java/com/github/kagkarlsson/scheduler/functional/ImmediateExecutionTest.java b/...ler/src/test/java/com/github/kagkarlsson/scheduler/functional/ImmediateExecutionTest.java
@@ -41,7 +41,7 @@ public void setUp() {
 
     @Test
     public void test_immediate_execution() {
-        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(20), () -> {
+        Assertions.assertTimeoutPreemptively(Duration.ofSeconds(10), () -> {
 
             Instant now = Instant.now();
             OneTimeTask<Void> task = TestTasks.oneTime("onetime-a", Void.class, TestTasks.DO_NOTHING);