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 ) ; } }
Fetch the flow that is dispatched and not yet finished by execution id .