Method start

methods/MIRIX/mirix/queue/worker.py:335–348

Start the background worker as an asyncio.Task.

(self)

                logger.error("Error in message consumption loop: %s", e, exc_info=True)

    async def start(self) -> None:
        """Start the background worker as an asyncio.Task."""
        if self._running:
            logger.warning("Queue worker already running")
            return

        partition_info = f" (partition {self._partition_id})" if self._partition_id is not None else ""
        logger.info("Starting queue worker task%s...", partition_info)
        self._running = True

        task_name = f"QueueWorker-{self._partition_id}" if self._partition_id is not None else "QueueWorker"
        self._task = asyncio.create_task(self._consume_loop(), name=task_name)

        logger.info("Queue worker task%s started successfully", partition_info)

    async def stop(self, close_queue: bool = True) -> None:
        """