@Test
public void testOutOfServiceJobWithRealStateNotRegistered() {

    jobManagerStub.moveTaskToState(taskId1, TaskState.Started);
    StepVerifier.create(healthService.events(false))
            // Check enabled job for not registered container
            .then(eurekaServer::triggerCacheRefreshUpdate)
            .assertNext(event -> assertContainerHealthAndEvent(event, healthService.getHealthStatus(taskId1), taskId1, ContainerHealthState.Unknown))
            // Disable job
            .then(() -> jobManagerStub.changeJobEnabledStatus(job1, false))
            .assertNext(event -> assertContainerHealthAndEvent(event, healthService.getHealthStatus(taskId1), taskId1, ContainerHealthState.Healthy))
            // Enable again
            .then(() -> jobManagerStub.changeJobEnabledStatus(job1, true))
            .assertNext(event -> assertContainerHealthAndEvent(event, healthService.getHealthStatus(taskId1), taskId1, ContainerHealthState.Unknown))
            .thenCancel()
            .verify(Duration.ofSeconds(5));
}