code: def assure_queue(fnc):
      
      @wraps(fnc)
      def _wrapped(self, queue, *args, **kwargs):
          if not isinstance(queue, Queue):
              # Must be the ID
              queue = self._manager.get(queue)
          return fnc(self, queue, *args, **kwargs)
      return _wrapped
docs: Converts a queue ID or name passed as the 'queue' parameter to a Queue
      object.