Skip to content

Commit 6ca54f0

Browse files
committed
fix(datashare-tasks): fix TaskManagerTemporalIntTest by using immediately consistent search APIs in tests
1 parent d403dd1 commit 6ca54f0

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

datashare-tasks/src/test/java/org/icij/datashare/asynctasks/TaskManagerTemporalIntTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -218,11 +218,11 @@ public void test_task_error() throws IOException, InterruptedException {
218218
public void test_clear() throws IOException {
219219
String taskId = taskManager.startTask("taskName1", User.local(), Map.of());
220220

221-
assertThat(taskManager.getTasks().toList()).hasSize(1);
221+
assertThat(taskManager.getTaskIds().toList()).hasSize(1);
222222
taskManager.clear();
223223

224224
assertThrows(UnknownTask.class, () -> taskManager.getTask(taskId));
225-
assertThat(taskManager.getTasks().toList()).hasSize(0);
225+
assertThat(taskManager.getTaskIds().toList()).hasSize(0);
226226
}
227227

228228
@Test
@@ -233,7 +233,7 @@ public void test_clear_task() throws IOException {
233233

234234
assertThat(taskId).isEqualTo(clearedTask.id);
235235
assertThrows(UnknownTask.class, () -> taskManager.getTask(taskId));
236-
assertThat(taskManager.getTasks().toList()).hasSize(0);
236+
assertThat(taskManager.getTaskIds().toList()).hasSize(0);
237237
}
238238

239239
@Ignore("keeping this one for manual test as it can take very long to complete")
@@ -243,7 +243,7 @@ public void test_clear_done_tasks() throws Exception {
243243
Task<String> task = new Task<>("hello-world", User.local(), Map.of("key", "value"));
244244
taskManager.startTask(task);
245245
assertThat(taskManager.awaitTermination(2, TimeUnit.SECONDS));
246-
assertThat(taskManager.getTasks().toList()).hasSize(1);
246+
assertThat(taskManager.getTaskIds().toList()).hasSize(1);
247247

248248
taskManager.clearDoneTasks();
249249

0 commit comments

Comments
 (0)