class ExecutionFailureHandler {

	public FailureHandlingResult getGlobalFailureHandlingResult(final Throwable cause) {
		return handleFailure(
			cause,
			IterableUtils.toStream(schedulingTopology.getVertices())
				.map(SchedulingExecutionVertex::getId)
				.collect(Collectors.toSet()),
			true);
	}

	public  ExecutionFailureHandler(
			final SchedulingTopology schedulingTopology,
			final FailoverStrategy failoverStrategy,
			final RestartBackoffTimeStrategy restartBackoffTimeStrategy);

}