Skip to content

Commit 276e8da

Browse files
committed
added missing transaction wrapper
1 parent ad28f1f commit 276e8da

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

core/src/main/java/org/sterl/spring/persistent_tasks/scheduler/SchedulerService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ public List<Future<TriggerKey>> triggerNextTasks(OffsetDateTime timeDue) {
108108
triggers = Collections.emptyList();
109109
}
110110
var result = taskExecutor.submit(triggers);
111-
pingRegistry();
111+
trx.executeWithoutResult(t -> this.pingRegistry());
112112
return result;
113113
}
114114

core/src/test/java/org/sterl/spring/persistent_tasks/scheduler/SchedulerServiceTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ void testWillTriggerOnlyFreeThreadSize() throws Exception {
4444
for (int i = 0; i < 15; i++) {
4545
triggerService.queue(TaskTriggerBuilder
4646
.newTrigger("slowTask")
47-
.state(50L)
47+
.state(200L)
4848
.build()
4949
);
5050
}
@@ -53,9 +53,9 @@ void testWillTriggerOnlyFreeThreadSize() throws Exception {
5353
subject.triggerNextTasks();
5454

5555
// THEN
56-
Thread.sleep(15);
5756
assertThat(triggerService.countTriggers(TriggerStatus.RUNNING)).isEqualTo(10);
5857
assertThat(triggerService.countTriggers(TriggerStatus.WAITING)).isEqualTo(5);
58+
5959
// AND
6060
final SchedulerEntity scheduler = subject.getScheduler();
6161
assertThat(scheduler.getRunnungTasks()).isEqualTo(10);

0 commit comments

Comments
 (0)