@Test
public void testFetchAllActiveFlows() throws Exception {

  initializeUnfinishedFlows();
  final List<ExecutableFlow> flows = this.controller.getRunningFlows();
  this.unfinishedFlows.values()
      .forEach(pair -> assertThat(flows.contains(pair.getSecond())).isTrue());
}