code: Pair<ExecutionReference, ExecutableFlow> fetchActiveFlowByExecId(final int execId)
        throws ExecutorManagerException {
      try {
        return this.dbOperator.query(FetchActiveExecutableFlow
                .FETCH_ACTIVE_EXECUTABLE_FLOW_BY_EXEC_ID,
            new FetchActiveExecutableFlow(), execId);
      } catch (final SQLException e) {
        throw new ExecutorManagerException("Error fetching active flow by exec id" + execId, e);
      }
    }
docs: Fetch the flow that is dispatched and not yet finished by execution id.
  
  @return active flow pair
  @throws ExecutorManagerException the executor manager exception