code: def not_send_status(func):
      
      @functools.wraps(func)
      def wrapper(self, response, task):
          self._extinfo['not_send_status'] = True
          function = func.__get__(self, self.__class__)
          return self._run_func(function, response, task)
      return wrapper
docs: Do not send process status package back to scheduler.
  
      It's used by callbacks like on_message, on_result etc...