|
9 | 9 | import pytest
|
10 | 10 | import importlib
|
11 | 11 | import contextlib
|
12 |
| -import requests |
13 |
| -import aiohttp |
14 |
| -import yarl |
15 | 12 | import functools
|
16 | 13 | import openai
|
17 | 14 | from devtools_testutils.sanitizers import add_header_regex_sanitizer, add_oauth_response_sanitizer
|
|
21 | 18 | get_bearer_token_provider as get_bearer_token_provider_async,
|
22 | 19 | )
|
23 | 20 |
|
24 |
| -# controls whether we run tests against v0 or v1. Options: v0 or v1. Default: v1 |
25 |
| -ENV_OPENAI_TEST_MODE = "OPENAI_TEST_MODE" |
26 | 21 |
|
27 | 22 | # for pytest.parametrize
|
28 | 23 | AZURE = "azure"
|
@@ -128,12 +123,9 @@ def azure_openai_creds():
|
128 | 123 | "chat_completion_gpt4_model": ENV_OPENAI_CHAT_COMPLETIONS_GPT4_MODEL,
|
129 | 124 | }
|
130 | 125 |
|
131 |
| -# openai>=1.0.0 --------------------------------------------------------------------------- |
132 | 126 |
|
133 | 127 | @pytest.fixture
|
134 | 128 | def client(api_type):
|
135 |
| - if os.getenv(ENV_OPENAI_TEST_MODE, "v1") != "v1": |
136 |
| - pytest.skip("Skipping - tests set to run against v1.") |
137 | 129 | if api_type == "azure":
|
138 | 130 | client = openai.AzureOpenAI(
|
139 | 131 | azure_endpoint=os.getenv(ENV_AZURE_OPENAI_ENDPOINT),
|
@@ -179,8 +171,6 @@ def client(api_type):
|
179 | 171 |
|
180 | 172 | @pytest.fixture
|
181 | 173 | def client_async(api_type):
|
182 |
| - if os.getenv(ENV_OPENAI_TEST_MODE, "v1") != "v1": |
183 |
| - pytest.skip("Skipping - tests set to run against v1.") |
184 | 174 | if api_type == "azure":
|
185 | 175 | client = openai.AsyncAzureOpenAI(
|
186 | 176 | azure_endpoint=os.getenv(ENV_AZURE_OPENAI_ENDPOINT),
|
@@ -308,70 +298,3 @@ def reload():
|
308 | 298 | yield
|
309 | 299 | finally:
|
310 | 300 | importlib.reload(openai)
|
311 |
| - |
312 |
| - |
313 |
| -# openai<1.0.0 --------------------------------------------------------------------------- |
314 |
| - |
315 |
| -@pytest.fixture |
316 |
| -def set_vars(api_type): |
317 |
| - if os.getenv(ENV_OPENAI_TEST_MODE, "v1") != "v0": |
318 |
| - pytest.skip("Skipping - tests set to run against v0.") |
319 |
| - |
320 |
| - if api_type == "azure": |
321 |
| - openai.api_base = os.getenv(ENV_AZURE_OPENAI_ENDPOINT).rstrip("/") |
322 |
| - openai.api_key = os.getenv(ENV_AZURE_OPENAI_KEY) |
323 |
| - openai.api_type = "azure" |
324 |
| - openai.api_version = ENV_AZURE_OPENAI_API_VERSION |
325 |
| - elif api_type == "azuread": |
326 |
| - openai.api_base = os.getenv(ENV_AZURE_OPENAI_ENDPOINT).rstrip("/") |
327 |
| - credential = DefaultAzureCredential() |
328 |
| - token = credential.get_token("https://cognitiveservices.azure.com/.default") |
329 |
| - openai.api_type = "azuread" |
330 |
| - openai.api_key = token.token |
331 |
| - openai.api_version = ENV_AZURE_OPENAI_API_VERSION |
332 |
| - elif api_type == "openai": |
333 |
| - openai.api_base = "https://api.openai.com/v1" |
334 |
| - openai.api_type = "openai" |
335 |
| - openai.api_key = os.getenv(ENV_OPENAI_KEY) |
336 |
| - openai.api_version = None |
337 |
| - elif api_type == "whisper_azure": |
338 |
| - openai.api_base = os.getenv(ENV_AZURE_OPENAI_NORTHCENTRALUS_ENDPOINT).rstrip("/") |
339 |
| - openai.api_key = os.getenv(ENV_AZURE_OPENAI_NORTHCENTRALUS_KEY) |
340 |
| - openai.api_type = "azure" |
341 |
| - openai.api_version = ENV_AZURE_OPENAI_API_VERSION |
342 |
| - elif api_type == "whisper_azuread": |
343 |
| - openai.api_base = os.getenv(ENV_AZURE_OPENAI_NORTHCENTRALUS_ENDPOINT).rstrip("/") |
344 |
| - credential = DefaultAzureCredential() |
345 |
| - token = credential.get_token("https://cognitiveservices.azure.com/.default") |
346 |
| - openai.api_type = "azuread" |
347 |
| - openai.api_key = token.token |
348 |
| - openai.api_version = ENV_AZURE_OPENAI_API_VERSION |
349 |
| - |
350 |
| - |
351 |
| -def configure_v0_async(f): |
352 |
| - @functools.wraps(f) |
353 |
| - async def wrapper(*args, **kwargs): |
354 |
| - api_type = kwargs.pop("api_type") |
355 |
| - set_vars = kwargs.pop("set_vars") |
356 |
| - azure_openai_creds = kwargs.pop("azure_openai_creds") |
357 |
| - try: |
358 |
| - return await f(*args, set_vars=set_vars, azure_openai_creds=azure_openai_creds, api_type=api_type, **kwargs) |
359 |
| - except openai.error.RateLimitError: |
360 |
| - pytest.skip(f"{str(f).split(' ')[1]}[{api_type}]: Skipping - Rate limit reached.") |
361 |
| - |
362 |
| - return wrapper |
363 |
| - |
364 |
| - |
365 |
| -def configure_v0(f): |
366 |
| - @functools.wraps(f) |
367 |
| - def wrapper(*args, **kwargs): |
368 |
| - api_type = kwargs.pop("api_type") |
369 |
| - set_vars = kwargs.pop("set_vars") |
370 |
| - azure_openai_creds = kwargs.pop("azure_openai_creds") |
371 |
| - try: |
372 |
| - return f(*args, set_vars=set_vars, azure_openai_creds=azure_openai_creds, api_type=api_type, **kwargs) |
373 |
| - except openai.error.RateLimitError: |
374 |
| - pytest.skip(f"{str(f).split(' ')[1]}[{api_type}]: Skipping - Rate limit reached.") |
375 |
| - |
376 |
| - return wrapper |
377 |
| - |
0 commit comments