@Test
public void findTaskErrors() {

    cellOne.getServiceRegistry().addService(new CellWithFailingJobManagementService(INTERNAL));
    cellTwo.getServiceRegistry().addService(new CellWithFailingJobManagementService(UNAVAILABLE));
    AssertableSubscriber<Task> testSubscriber = service.findTask("any", UNDEFINED_CALL_METADATA).test();
    testSubscriber.awaitTerminalEvent(1, TimeUnit.SECONDS);
    // unexpected errors have higher precedence than transient
    testSubscriber.assertError(StatusRuntimeException.class);
    assertThat(Status.fromThrowable(testSubscriber.getOnErrorEvents().get(0))).isEqualTo(INTERNAL);
}