Method send_request

unity_cli/client.py:227–259

Send REQUEST message with exponential backoff retry.

(
        self,
        command: str,
        params: dict[str, Any],
        timeout_ms: int | None = None,
        retry_initial_ms: int | None = None,
        retry_max_ms: int | None = None,
        retry_max_time_ms: int | None = None,
    )

    _RETRYABLE_CODES = frozenset({"INSTANCE_RELOADING", "INSTANCE_BUSY", "TIMEOUT", "INSTANCE_DISCONNECTED"})

    def send_request(
        self,
        command: str,
        params: dict[str, Any],
        timeout_ms: int | None = None,
        retry_initial_ms: int | None = None,
        retry_max_ms: int | None = None,
        retry_max_time_ms: int | None = None,
    ) -> dict[str, Any]:
        """Send REQUEST message with exponential backoff retry."""
        timeout_ms = timeout_ms if timeout_ms is not None else self.timeout_ms
        retry_initial_ms = retry_initial_ms if retry_initial_ms is not None else self.retry_initial_ms
        retry_max_ms = retry_max_ms if retry_max_ms is not None else self.retry_max_ms
        retry_max_time_ms = retry_max_time_ms if retry_max_time_ms is not None else self.retry_max_time_ms

        request_id = _generate_request_id(self._client_id)
        start_time = time.time()
        attempt = 0

        while True:
            elapsed_ms = (time.time() - start_time) * 1000

            if attempt > 0 and elapsed_ms >= retry_max_time_ms:
                raise TimeoutError(
                    f"Max retry time exceeded ({retry_max_time_ms}ms) for '{command}'",
                    "RETRY_TIMEOUT",
                )

            try:
                return self._send_request_once(request_id, command, params, timeout_ms)
            except (InstanceError, TimeoutError) as e:
                self._maybe_retry(e, command, elapsed_ms, retry_initial_ms, retry_max_ms, retry_max_time_ms, attempt)
                attempt += 1

    def _maybe_retry(
        self,