Method flush_queue

relay/instance_registry.py:150–168

Flush all queued commands with an error. Called when instance goes to RELOADING or DISCONNECTED state.

(self, error_code: str, error_message: str)

        return None

    def flush_queue(self, error_code: str, error_message: str) -> None:
        """
        Flush all queued commands with an error.
        Called when instance goes to RELOADING or DISCONNECTED state.
        """
        from .protocol import ErrorCode, ErrorMessage

        while self.command_queue:
            cmd = self.command_queue.popleft()
            if not cmd.future.done():
                error_response = ErrorMessage.from_code(
                    cmd.request_id,
                    ErrorCode(error_code) if hasattr(ErrorCode, error_code) else ErrorCode.INTERNAL_ERROR,
                    error_message,
                ).to_dict()
                cmd.future.set_result(error_response)
                logger.debug(f"Flushed queued command {cmd.request_id}: {error_code}")

        logger.info(f"Flushed command queue for {self.instance_id}")

    async def close_connection(self) -> None:
        """Close the connection to this instance"""