code: Map<Integer, Pair<ExecutionReference, ExecutableFlow>> fetchActiveFlows()
        throws ExecutorManagerException {
      try {
        return this.dbOperator.query(FetchActiveExecutableFlows.FETCH_ACTIVE_EXECUTABLE_FLOWS,
            new FetchActiveExecutableFlows());
      } catch (final SQLException e) {
        throw new ExecutorManagerException("Error fetching active flows", e);
      }
    }
docs: Fetch flows that are dispatched and not yet finished.
  
  @return active flows map
  @throws ExecutorManagerException the executor manager exception