code: def stop(self):
          
          if not self.running.wait(0.2):
              return
          self._logger.debug('runner disabled: %s', self)
          with self._lock:
              self.running.clear()
          self._stopped.wait()
docs: Stop execution of all current and future payloads