code: Map<Integer, Pair<ExecutionReference, ExecutableFlow>> fetchUnfinishedFlows()
        throws ExecutorManagerException {
      try {
        return this.dbOperator.query(FetchActiveExecutableFlows.FETCH_UNFINISHED_EXECUTABLE_FLOWS,
            new FetchActiveExecutableFlows());
      } catch (final SQLException e) {
        throw new ExecutorManagerException("Error fetching unfinished flows", e);
      }
    }
docs: Fetch flows that are not in finished status, including both dispatched and non-dispatched
  flows.
  
  @return unfinished flows map
  @throws ExecutorManagerException the executor manager exception