Compatibility test for priority

kagkarlsson · Sep 27, 2024 · 8aed4fe · 8aed4fe
1 parent 7f53146
commit 8aed4fe
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...duler/src/test/java/com/github/kagkarlsson/scheduler/compatibility/CompatibilityTest.java b/...duler/src/test/java/com/github/kagkarlsson/scheduler/compatibility/CompatibilityTest.java
@@ -274,6 +274,9 @@ private void doJDBCRepositoryCompatibilityTestUsingData(String data) {
     Execution storedExecution = (jdbcTaskRepository.getExecution(taskInstance)).get();
     assertThat(storedExecution.getExecutionTime(), is(now));
 
+    // priority=true
+    assertThat(jdbcTaskRepository.getDue(now, POLLING_LIMIT, true), hasSize(1));
+    // priority=false
     final List<Execution> due = jdbcTaskRepository.getDue(now, POLLING_LIMIT, false);
     assertThat(due, hasSize(1));
     final Optional<Execution> pickedExecution = jdbcTaskRepository.pick(due.get(0), now);