@Test
public void testFetchActiveFlowWithExecutor() throws Exception {

  initializeUnfinishedFlows();
  final List<Pair<ExecutableFlow, Optional<Executor>>> activeFlowsWithExecutor =
      this.controller.getActiveFlowsWithExecutor();
  this.unfinishedFlows.values().forEach(pair -> assertThat(activeFlowsWithExecutor
      .contains(new Pair<>(pair.getSecond(), pair.getFirst().getExecutor()))).isTrue());
}