@Test
public void observeJobDoesNotSetDeadlines() throws InterruptedException {

    String cellOneJobId = UUID.randomUUID().toString();
    String cellTwoJobId = UUID.randomUUID().toString();
    cellOne.getServiceRegistry().addService(new CellWithJobStream(cellOneJobId, cellOneUpdates.serialize()));
    cellTwo.getServiceRegistry().addService(new CellWithJobStream(cellTwoJobId, cellTwoUpdates.serialize()));
    List<AssertableSubscriber<JobChangeNotification>> subscribers = new LinkedList<>();
    subscribers.add(service.observeJob(cellOneJobId, UNDEFINED_CALL_METADATA).test());
    subscribers.add(service.observeJob(cellTwoJobId, UNDEFINED_CALL_METADATA).test());
    // TODO: make it easier to extract the Deadline for each cell call
    Thread.sleep(2 * GRPC_REQUEST_TIMEOUT_MS);
    for (AssertableSubscriber<JobChangeNotification> subscriber : subscribers) {
        subscriber.assertNoErrors();
        subscriber.assertNotCompleted();
        assertThat(subscriber.isUnsubscribed()).isFalse();
    }
}