Skip to content

Commit 93a4ba6

Browse files
committed
adjusted test
1 parent 6746077 commit 93a4ba6

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

spring-persistent-tasks/src/test/java/org/sterl/spring/persistent_tasks/scheduler/SchedulerServiceTest.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -106,21 +106,20 @@ void testQueuedInFuture() {
106106
void runSimpleTaskMultipleTimesTest() throws Exception {
107107
// GIVEN
108108
TaskId<String> taskId = taskService.replace("foo", c -> asserts.info(c));
109-
for (int i = 1; i < 5; ++i) {
109+
for (int i = 1; i < 21; ++i) {
110110
subject.queue(taskId, i + " state");
111111
}
112112

113113
// WHEN
114-
for (int i = 1; i < 5; ++i) {
115-
subject.triggerNextTasks();
116-
}
114+
schedulerA.triggerNextTasks();
115+
schedulerB.triggerNextTasks();
117116

118117
// THEN
119-
for (int i = 1; i < 5; ++i) {
118+
for (int i = 1; i < 21; ++i) {
120119
asserts.awaitValue(i + " state");
121120
}
122121

122+
assertThat(historyService.countTriggers(TriggerStatus.SUCCESS)).isEqualTo(20);
123123
assertThat(triggerService.hasPendingTriggers()).isFalse();
124-
assertThat(historyService.countTriggers(TriggerStatus.SUCCESS)).isEqualTo(4);
125124
}
126125
}

0 commit comments

Comments
 (0)