.flatMap(driver -> driver.getBlockedReasons().stream())
.collect(ImmutableCollectors.toImmutableSet());
boolean fullyBlocked = drivers.stream()
.filter(driver -> driver.getEndTime() == null && driver.getStartTime() != null)
.allMatch(DriverStats::isFullyBlocked);
<BUG>return new PipelineStats(
executionStartTime.get(),</BUG>
lastExecutionStartTime.get(),
lastExecutionEndTime.get(),
inputPipeline,

.flatMap(driver -> driver.getBlockedReasons().stream())
.collect(ImmutableCollectors.toImmutableSet());
boolean fullyBlocked = drivers.stream()
.filter(driver -> driver.getEndTime() == null && driver.getStartTime() != null)
.allMatch(DriverStats::isFullyBlocked);
return new PipelineStats(
pipelineId,
executionStartTime.get(),
lastExecutionStartTime.get(),
lastExecutionEndTime.get(),
inputPipeline,
