@Test
public void testOutOfServiceJobWithRealStateUp() {

    jobManagerStub.moveTaskToState(taskId1, TaskState.Started);
    StepVerifier.create(healthService.events(false))
            // Change state to OUT_OF_SERVICE
            .then(() -> {
                jobManagerStub.changeJobEnabledStatus(job1, false);
                registerAndRefresh(InstanceStatus.OUT_OF_SERVICE);
            })
            .assertNext(event -> assertContainerHealthAndEvent(event, healthService.getHealthStatus(taskId1), taskId1, ContainerHealthState.Healthy))
            .thenCancel()
            .verify(Duration.ofSeconds(5));
}