@Override
  public CompletableFuture<Void> asyncAddTaskExecutionLogs(List<TaskExecLog> logs) {
    return CompletableFuture.runAsync(() -> addTaskExecutionLogs(logs));
  }
@Test
  public void asyncAddTaskExecutionLogsTest() throws Exception {
    List<TaskExecLog> logs = new ArrayList<>();
    logs.add(createLog(TEST_TASK_ID_2, "log1"));
    logs.add(createLog(TEST_TASK_ID_2, "log2"));
    logs.add(createLog(TEST_TASK_ID_2, "log3"));

    dao.asyncAddTaskExecutionLogs(logs).get();

    List<TaskExecLog> indexedLogs =
        tryFindResults(() -> dao.getTaskExecutionLogs(TEST_TASK_ID_2), 3);

    assertEquals(3, indexedLogs.size());

    assertTrue("Not all logs was indexed", indexedLogs.containsAll(logs));
  }