code: def empty(self):
          
          with context.connections.redis.pipeline(transaction=True) as pipe:
              pipe.delete(self.redis_key)
              pipe.delete(self.redis_key_known_subqueues)
              pipe.execute()
docs: Empty a queue.