TestVertexGemmaiCompletion

This commit is contained in:
Ishaan Jaffer 2025-10-09 18:31:03 -07:00
parent 4827e62a21
commit 999c561179

View file

@ -0,0 +1,217 @@
"""
Mocked tests for Vertex AI Gemma-AI Models
Maps to: litellm/llms/vertex_ai/vertex_gemmai_models/transformation.py
"""
import json
from unittest.mock import AsyncMock, Mock, patch
import pytest
import litellm
class TestVertexGemmaiCompletion:
"""Test completion flow for Vertex AI Gemmai models using litellm.acompletion()"""
@pytest.mark.asyncio
async def test_acompletion_basic_request(self):
"""
Test litellm.acompletion() with Vertex AI Gemmai model
Expected URL:
https://322775931984805888.us-central1-10582012152.prediction.vertexai.goog/v1/projects/PROJECT_ID/locations/us-central1/endpoints/ENDPOINT_ID:predict
Expected Request Body (sent to Vertex):
{
"instances": [
{
"@requestFormat": "chatCompletions",
"messages": [
{
"role": "user",
"content": "What is machine learning?"
}
],
"max_tokens": 100
}
]
}
Expected Vertex Response:
{
"deployedModelId": "6907280479758581760",
"model": "projects/993702345710/locations/us-central1/models/gemma-3-12b-it-1759525599171",
"modelDisplayName": "gemma-3-12b-it-1759525599171",
"modelVersionId": "1",
"predictions": {
"choices": [
{
"finish_reason": "length",
"index": 0,
"logprobs": null,
"message": {
"content": "Okay, let's break down machine learning...",
"reasoning_content": null,
"role": "assistant",
"tool_calls": []
},
"stop_reason": null
}
],
"created": 1759863903,
"id": "chatcmpl-aaa4288f-2b8e-4bc0-8b14-4e444decd2c4",
"model": "google/gemma-3-12b-it",
"object": "chat.completion",
"prompt_logprobs": null,
"usage": {
"completion_tokens": 100,
"prompt_tokens": 14,
"prompt_tokens_details": null,
"total_tokens": 114
}
}
}
Expected LiteLLM Response: Standard OpenAI format
"""
# Real Vertex response from user's spec
mock_vertex_response = {
"deployedModelId": "6907280479758581760",
"model": "projects/993702345710/locations/us-central1/models/gemma-3-12b-it-1759525599171",
"modelDisplayName": "gemma-3-12b-it-1759525599171",
"modelVersionId": "1",
"predictions": {
"choices": [
{
"finish_reason": "length",
"index": 0,
"logprobs": None,
"message": {
"content": "Okay, let's break down machine learning. Here's a comprehensive explanation, covering the core concepts, types, and some examples, tailored to different levels of understanding. I'll structure it into sections: **The Core Idea**, **Types of Machine Learning**, **How It Works (Simplified)**, **Examples**, and **Why It's Useful**.\n\n**1. The Core Idea: Learning from Data**\n\nAt its heart, machine learning (ML) is about enabling computers",
"reasoning_content": None,
"role": "assistant",
"tool_calls": [],
},
"stop_reason": None,
}
],
"created": 1759863903,
"id": "chatcmpl-aaa4288f-2b8e-4bc0-8b14-4e444decd2c4",
"model": "google/gemma-3-12b-it",
"object": "chat.completion",
"prompt_logprobs": None,
"usage": {
"completion_tokens": 100,
"prompt_tokens": 14,
"prompt_tokens_details": None,
"total_tokens": 114,
},
},
}
# Mock the async HTTP handler
with patch(
"litellm.llms.custom_httpx.http_handler.AsyncHTTPHandler"
) as mock_http_handler:
mock_response = Mock()
mock_response.status_code = 200
mock_response.json.return_value = mock_vertex_response
mock_http_handler.return_value.post = AsyncMock(return_value=mock_response)
# Call litellm.acompletion()
response = await litellm.acompletion(
model="vertex_ai/gemmai/gemma-3-12b-it-1759525599171",
messages=[{"role": "user", "content": "What is machine learning?"}],
max_tokens=100,
api_base="https://322775931984805888.us-central1-10582012152.prediction.vertexai.goog/v1/projects/PROJECT_ID/locations/us-central1/endpoints/ENDPOINT_ID:predict",
vertex_project="PROJECT_ID",
vertex_location="us-central1",
)
# Verify the request sent to Vertex
call_args = mock_http_handler.return_value.post.call_args
assert call_args is not None, "HTTP handler was not called"
request_data = call_args.kwargs["json"]
request_url = call_args.kwargs["url"]
# Validate exact URL matches what we sent
expected_url = "https://322775931984805888.us-central1-10582012152.prediction.vertexai.goog/v1/projects/PROJECT_ID/locations/us-central1/endpoints/ENDPOINT_ID:predict"
assert request_url == expected_url, f"Expected URL: {expected_url}\nActual URL: {request_url}"
# Validate Request Body matches expected format
assert "instances" in request_data
assert len(request_data["instances"]) == 1
outer_instance = request_data["instances"][0]
assert outer_instance["@requestFormat"] == "chatCompletions"
# The actual instance with messages is nested inside
assert "instances" in outer_instance
inner_instance = outer_instance["instances"][0]
assert inner_instance["@requestFormat"] == "chatCompletions"
assert "messages" in inner_instance
assert inner_instance["messages"][0]["role"] == "user"
assert inner_instance["messages"][0]["content"] == "What is machine learning?"
assert inner_instance["max_tokens"] == 100
# Validate LiteLLM Response (OpenAI format)
assert response.id == "chatcmpl-aaa4288f-2b8e-4bc0-8b14-4e444decd2c4"
assert response.object == "chat.completion"
assert response.created == 1759863903
# Model name has the gemmai/ prefix stripped during processing
assert response.model == "gemma-3-12b-it-1759525599171"
# Validate choices
assert len(response.choices) == 1
assert response.choices[0].index == 0
assert response.choices[0].finish_reason == "length"
assert response.choices[0].message.role == "assistant"
assert "machine learning" in response.choices[0].message.content.lower()
# Validate usage
assert response.usage.prompt_tokens == 14
assert response.usage.completion_tokens == 100
assert response.usage.total_tokens == 114
@pytest.mark.asyncio
async def test_acompletion_error_handling(self):
"""
Test litellm.acompletion() error handling when Vertex returns invalid response
Expected: Proper error handling when 'predictions' field is missing
"""
from litellm.exceptions import APIConnectionError
# Invalid response without predictions field
invalid_response = {
"deployedModelId": "123",
"error": {
"code": 400,
"message": "Invalid request"
}
}
with patch(
"litellm.llms.custom_httpx.http_handler.AsyncHTTPHandler"
) as mock_http_handler:
mock_response = Mock()
mock_response.status_code = 200
mock_response.json.return_value = invalid_response
mock_http_handler.return_value.post = AsyncMock(return_value=mock_response)
# Should raise exception (wrapped as APIConnectionError by LiteLLM)
with pytest.raises(APIConnectionError) as exc_info:
await litellm.acompletion(
model="vertex_ai/gemmai/gemma-3-12b-it",
messages=[{"role": "user", "content": "Test"}],
api_base="https://test.prediction.vertexai.goog/v1/projects/test/locations/us-central1/endpoints/123:predict",
vertex_project="test-project",
vertex_location="us-central1",
)
# Verify the error message contains the original error
assert "missing 'predictions' field" in str(exc_info.value)