Method _process_queue

relay/server.py:411–444

Process the next command in the instance's queue. Called after a command completes.

(self, instance: UnityInstance)

            self._pending_pongs.pop(instance_id, None)

    async def _process_queue(self, instance: UnityInstance) -> None:
        """
        Process the next command in the instance's queue.
        Called after a command completes.
        """
        if not instance.queue_enabled or not instance.command_queue:
            return

        # Get next command from queue
        queued_cmd = instance.dequeue_command()
        if not queued_cmd:
            return

        # Check if the future is still valid (not cancelled/timed out)
        if queued_cmd.future.done():
            logger.debug(f"Skipping already-done queued command: {queued_cmd.request_id}")
            # Recursively process next in queue
            await self._process_queue(instance)
            return

        logger.info(f"Processing queued command: {queued_cmd.request_id}")

        # Execute the queued command
        result = await self._execute_command(
            request_id=queued_cmd.request_id,
            instance_id=instance.instance_id,
            command=queued_cmd.command,
            params=queued_cmd.params,
            timeout_ms=queued_cmd.timeout_ms,
        )

        # Set the result on the future
        if not queued_cmd.future.done():
            queued_cmd.future.set_result(result)

    # ===== CLI Message Handling =====