summaryrefslogtreecommitdiffstats
path: root/testing/test_async.py
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--testing/test_async.py19
1 files changed, 7 insertions, 12 deletions
diff --git a/testing/test_async.py b/testing/test_async.py
index bef2c75f..76b109b1 100644
--- a/testing/test_async.py
+++ b/testing/test_async.py
@@ -5,31 +5,26 @@ import asyncio
sys.path.append(str(Path(__file__).parent.parent))
import g4f
-from g4f.Provider import AsyncProvider
from testing.test_providers import get_providers
from testing.log_time import log_time_async
async def create_async(provider):
- model = g4f.models.gpt_35_turbo.name if provider.supports_gpt_35_turbo else g4f.models.default.name
try:
response = await log_time_async(
provider.create_async,
- model=model,
- messages=[{"role": "user", "content": "Hello Assistant!"}]
+ model=g4f.models.default.name,
+ messages=[{"role": "user", "content": "Hello, are you GPT 3.5?"}]
)
print(f"{provider.__name__}:", response)
except Exception as e:
- return f"{provider.__name__}: {e.__class__.__name__}: {e}"
+ print(f"{provider.__name__}: {e.__class__.__name__}: {e}")
async def run_async():
responses: list = [
- create_async(_provider)
- for _provider in get_providers()
- if _provider.working and issubclass(_provider, AsyncProvider)
+ create_async(provider)
+ for provider in get_providers()
+ if provider.working
]
- responses = await asyncio.gather(*responses)
- for error in responses:
- if error:
- print(error)
+ await asyncio.gather(*responses)
print("Total:", asyncio.run(log_time_async(run_async))) \ No newline at end of file