class PipelinedRegionSchedulingStrategy implements SchedulingStrategy {

	@Override
	public void restartTasks(final Set<ExecutionVertexID> verticesToRestart) {
		final Set<SchedulingPipelinedRegion> regionsToRestart = verticesToRestart.stream()
			.map(schedulingTopology::getPipelinedRegionOfVertex)
			.collect(Collectors.toSet());
		maybeScheduleRegions(regionsToRestart);
	}

	public  PipelinedRegionSchedulingStrategy(
			final SchedulerOperations schedulerOperations,
			final SchedulingTopology schedulingTopology);

}