void regionFinished(SchedulingPipelinedRegion region) {
        for (ConsumerRegionGroupExecutionView executionView :
                executionViewByRegion.getOrDefault(region, Collections.emptySet())) {
            executionView.regionFinished(region);
        }
    }
@Test
    void testRegionFinishedMultipleTimes() throws Exception {
        consumerRegionGroupExecutionViewMaintainer.regionFinished(consumerRegion);
        consumerRegionGroupExecutionViewMaintainer.regionFinished(consumerRegion);

        assertThat(consumerRegionGroupExecutionView.isFinished()).isTrue();
    }