code: def _decrement_stage(self):
          
  
          try:
  
              if self._cur_stage > 0:
                  self._cur_stage -= 1
                  self._completed_flag = threading.Event()  # reset
  
          except Exception, ex:
              raise EnTKError(text=ex)
docs: Purpose: Decrement stage pointer. Reset completed flag.