@Test
public void shouldNotStartJobOnBlockedException() {

    doAnswer((x) -> {throw new JobBlockedException("");})
            .when(jobMetaService).aquireRunLock(anyString(), anyString());
    Optional<String> jobUri = jobService.startAsyncJob("someType");
    assertThat(jobUri.isPresent(), is(false));
    verify(jobRepository, never()).createOrUpdate(any());
}