public List < PipelineResponseCommit > findNotPropagatedCommits ( Dashboard dashboard , Pipeline pipeline , PipelineStage stage , List < PipelineStage > pipelineStageList ) { Map < String , PipelineCommit > startingStage = findCommitsForStage ( dashboard , pipeline , stage ) ; List < PipelineResponseCommit > notPropagatedCommits = new ArrayList <> ( ) ; for ( Map . Entry < String , PipelineCommit > entry : startingStage . entrySet ( ) ) { PipelineResponseCommit commit = applyStageTimestamps ( new PipelineResponseCommit ( ( PipelineCommit ) entry . getValue ( ) ) , dashboard , pipeline , pipelineStageList ) ; notPropagatedCommits . add ( commit ) ; } return notPropagatedCommits ; }
get the commits for a given stage by finding which commits havent passed to a later stage