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