Ufoptg commited on
Commit
0b28a9a
1 Parent(s): 10d14b6

Update main.py

Browse files
Files changed (1) hide show
  1. main.py +7 -5
main.py CHANGED
@@ -43,6 +43,7 @@ from dotenv import load_dotenv
43
  from fastapi import Depends, FastAPI, Header, HTTPException, Query, Request
44
  from fastapi.responses import JSONResponse, StreamingResponse
45
  from gpytranslate import SyncTranslator
 
46
  from httpx import AsyncClient
47
  from pymongo import MongoClient
48
  from RyuzakiLib.hackertools.chatgpt import RendyDevChat
@@ -523,7 +524,7 @@ def dalle_3xl(item: Dalle3XL, api_key: None = Depends(validate_api_key)):
523
 
524
 
525
  @app.post("/UFoP/proteusv02")
526
- def proteusv0_2(item: ProteusV02, api_key: None = Depends(validate_api_key)):
527
  API_URL = SOURCE_PROTEUSV0_2_URL
528
  try:
529
  payload = {"inputs": item.query}
@@ -531,11 +532,12 @@ def proteusv0_2(item: ProteusV02, api_key: None = Depends(validate_api_key)):
531
  "Authorization": f"Bearer {HUGGING_TOKEN}",
532
  "Content-Type": "application/json",
533
  }
534
- response = requests.post(
535
- API_URL, headers=headers, json=payload, timeout=timeout
536
- )
 
537
  response.raise_for_status()
538
- except requests.exceptions.RequestException:
539
  raise HTTPException(status_code=500, detail=internal_error)
540
 
541
  try:
 
43
  from fastapi import Depends, FastAPI, Header, HTTPException, Query, Request
44
  from fastapi.responses import JSONResponse, StreamingResponse
45
  from gpytranslate import SyncTranslator
46
+ import httpx
47
  from httpx import AsyncClient
48
  from pymongo import MongoClient
49
  from RyuzakiLib.hackertools.chatgpt import RendyDevChat
 
524
 
525
 
526
  @app.post("/UFoP/proteusv02")
527
+ async def proteusv0_2(item: ProteusV02, api_key: None = Depends(validate_api_key)):
528
  API_URL = SOURCE_PROTEUSV0_2_URL
529
  try:
530
  payload = {"inputs": item.query}
 
532
  "Authorization": f"Bearer {HUGGING_TOKEN}",
533
  "Content-Type": "application/json",
534
  }
535
+ async with httpx.AsyncClient() as client:
536
+ response = await client.post(
537
+ API_URL, headers=headers, json=payload, timeout=timeout
538
+ )
539
  response.raise_for_status()
540
+ except httpx.HTTPStatusError:
541
  raise HTTPException(status_code=500, detail=internal_error)
542
 
543
  try: