@Test
public void getTaskById() {

    final CountDownLatch latch = new CountDownLatch(1);
    titusClient.getTask(taskOne.getId()).subscribe(task -> {
        assertThat(task.getId()).isEqualTo(taskOne.getId());
        assertThat(task.getJobId()).isEqualTo(taskOne.getJobId());
        latch.countDown();
    });
    try {
        latch.await(1, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
        fail("getTaskById Timeout ", e);
    }
}