code: def _increment_stage(self):
          
  
          try:
  
              if self._cur_stage < self._stage_count:
                  self._cur_stage += 1
              else:
                  self._completed_flag.set()
  
          except Exception, ex:
              raise EnTKError(text=ex)
docs: Purpose: Increment stage pointer. Also check if Pipeline has completed.