public void stop ( ) throws PipelineException { this . stop = true ; if ( batchesToCapture > 0 ) { cancelSnapshot ( this . snapshotName ) ; snapshotStore . deleteSnapshot ( pipelineName , revision , snapshotName ) ; } }
Stops execution of the pipeline after the current batch completes