Skip to content

Commit c9c7586

Browse files
committed
enabled test again
1 parent 0826b33 commit c9c7586

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

core/src/test/java/org/sterl/spring/persistent_tasks/AbstractSpringTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,7 @@ PersistentTask<Long> slowTask(AsyncAsserts asserts) {
172172
}
173173
}
174174

175-
protected void awaidHistoryThreads() {
175+
protected void awaitHistoryThreads() {
176176
Awaitility.await().until(() -> triggerHistoryExecutor.getActiveCount() == 0);
177177
}
178178

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ void testRunOrQueueTransactions() throws Exception {
185185
var k1 = subject.runOrQueue(TriggerBuilder.newTrigger("savePersonInTrx").state("Paul").build());
186186

187187
// THEN 1 to save and 1 to start it and 1 for the history
188-
awaidHistoryThreads();
188+
awaitHistoryThreads();
189189
hibernateAsserts.assertTrxCount(3);
190190
assertThat(persistentTaskService.getLastTriggerData(k1).get().getStatus())
191191
.isEqualTo(TriggerStatus.RUNNING);
@@ -194,7 +194,7 @@ void testRunOrQueueTransactions() throws Exception {
194194
hibernateAsserts.reset();
195195
COUNTDOWN.countDown();
196196
Awaitility.await().until(() -> hibernateAsserts.getStatistics().getTransactionCount() >= 1);
197-
awaidHistoryThreads();
197+
awaitHistoryThreads();
198198
hibernateAsserts.assertTrxCount(1);
199199

200200
// THEN

core/src/test/java/org/sterl/spring/persistent_tasks/task/TaskTransactionTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -160,8 +160,8 @@ void testRequiresNewHasOwnTransaction(String task) {
160160
assertThat(personRepository.count()).isEqualTo(1);
161161
}
162162

163-
//@ParameterizedTest
164-
//@ValueSource(strings = {"transactionalClass", "transactionalClassAndMethod", "transactionalClosure"})
163+
@ParameterizedTest
164+
@ValueSource(strings = {"transactionalClass", "transactionalClassAndMethod", "transactionalClosure"})
165165
void testTransactionalTask(String task) throws InterruptedException {
166166
// GIVEN
167167
personRepository.deleteAllInBatch();
@@ -174,7 +174,7 @@ void testTransactionalTask(String task) throws InterruptedException {
174174

175175
// THEN
176176
asserts.awaitValue(task);
177-
awaidHistoryThreads();
177+
awaitHistoryThreads();
178178
hibernateAsserts
179179
// running trigger
180180
//.assertDeletedCount(1)

0 commit comments

Comments
 (0)