Method _enqueue_command

relay/server.py:610–651

Handle BUSY instance by enqueuing or returning error.

(
        self,
        request_id: str,
        instance: UnityInstance,
        command: str,
        params: dict[str, Any],
        timeout_ms: int,
    )

        return False

    async def _enqueue_command(
        self,
        request_id: str,
        instance: UnityInstance,
        command: str,
        params: dict[str, Any],
        timeout_ms: int,
    ) -> dict[str, Any]:
        """Handle BUSY instance by enqueuing or returning error."""
        if not instance.queue_enabled:
            detail_suffix = f" ({instance.status_detail})" if instance.status_detail else ""
            return ErrorMessage.from_code(
                request_id,
                ErrorCode.INSTANCE_BUSY,
                f"Instance is busy{detail_suffix}: {instance.instance_id}. Retry the command after a few seconds.",
            ).to_dict()

        future: asyncio.Future[dict[str, Any]] = asyncio.Future()
        queued_cmd = QueuedCommand(
            request_id=request_id,
            command=command,
            params=params,
            timeout_ms=timeout_ms,
            future=future,
        )

        if not instance.enqueue_command(queued_cmd):
            return ErrorMessage.from_code(
                request_id,
                ErrorCode.QUEUE_FULL,
                f"Command queue is full (max: {QUEUE_MAX_SIZE}): {instance.instance_id}. Wait for current commands to complete before sending new ones.",
            ).to_dict()

        logger.info(f"[{request_id}] Command queued for {instance.instance_id} (queue size: {instance.queue_size})")
        try:
            return await asyncio.wait_for(future, timeout=timeout_ms / 1000)
        except TimeoutError:
            return ErrorMessage.from_code(
                request_id,
                ErrorCode.TIMEOUT,
                f"Queued command timed out after {timeout_ms}ms. The command was queued but did not complete in time. Consider increasing --timeout or retrying.",
            ).to_dict()

    async def _execute_command(
        self,