def rerun(self):

        """
        Rerun sets the state of the Pipeline to scheduling so that the Pipeline
        can be checked for new stages
        """

        self._state = states.SCHEDULING
        self._completed_flag = threading.Event()
        print 'Pipeline %s in %s state'%(self._uid, self._state)
def rerun ( self ) : self . _state = states . SCHEDULING self . _completed_flag = threading . Event ( ) print 'Pipeline %s in %s state' % ( self . _uid , self . _state )
Rerun sets the state of the Pipeline to scheduling so that the Pipeline
        can be checked for new stages