@Test
public void shouldInterruptWhenMarkerAsksForInterruption() {

    // given
    cleaner.setMarkers(Collections.singletonList(marker));
    when(marker.mark(any(), any(UUID.class))).thenReturn(StepMarker.Result.INTERRUPTED);
    // when
    cleaner.execute();
    // then
    verify(repository, never()).remove(refEq(Step.class), any(Expression.class));
}