@Test
public void shouldDisableCleanUpDuringProcess() {

    // Given
    final UUID stepMarker = UUID.randomUUID();
    final StepMarker marker = new PreparationStepMarker();
    final PreparationRepository repository = mock(PreparationRepository.class);
    when(repository.exist(eq(Preparation.class), any())).thenReturn(false, true);
    final Preparation preparation = new Preparation();
    when(repository.list(eq(Preparation.class))).thenReturn(Stream.of(preparation));
    // When
    final StepMarker.Result result = marker.mark(repository, stepMarker);
    // Then
    assertEquals(StepMarker.Result.INTERRUPTED, result);
    verify(repository, never()).add(Matchers.<Collection<Step>> any());
}