public List < Integer > getQueuedFlowIds ( ) { final List < Integer > allIds = new ArrayList <> ( ) ; try { getExecutionIdsHelper ( allIds , this . executorLoader . fetchQueuedFlows ( ) ) ; } catch ( final ExecutorManagerException e ) { this . logger . error ( "Failed to get queued flow ids." , e ) ; } return allIds ; }
Get execution ids of all non - dispatched flows from database .