Method update

ernie/refined_recompute/utils.py:146–161

Registers a new queue in the management system. Args: queue (queue.Queue): The queue object to register queue_name (str): Base identifier for the queue (default: "unknown") Note: Automatically appends the queue's memory address for uniqueness

(self, queue: queue.Queue, queue_name="unknown")

        self.rr_queue = defaultdict(queue.Queue)

    def update(self, queue: queue.Queue, queue_name="unknown"):
        """
        Registers a new queue in the management system.

        Args:
            queue (queue.Queue): The queue object to register
            queue_name (str): Base identifier for the queue (default: "unknown")
                Note: Automatically appends the queue's memory address for uniqueness

        Raises:
            ValueError: If a queue with the generated name already exists
        """
        queue_name = f"{queue_name}_{id(queue)}"
        if queue_name in self.rr_queue:
            raise ValueError(f"Queue name '{queue_name}' already exists.")
        self.rr_queue[queue_name] = queue

    def check(self):
        """