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 ) ; } }
Fetch flows that are not in finished status including both dispatched and non - dispatched flows .