alex/nova-api
1
0
Fork 0
mirror of https://github.com/NovaOSS/nova-api.git synced 2024-11-25 16:43:58 +01:00
Code Issues Packages Projects Releases Wiki Activity

i luv u @Zapzatron <3

Browse source
This commit is contained in:
NovaOSS Admins 2023-10-25 19:09:49 +00:00
parent 91ea380b79
commit fffd7a276a
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
api/responder.py
View file

@ -68,7 +68,8 @@ async def respond(
'insufficient_quota': 0, 'insufficient_quota': 0,
'billing_not_active': 0, 'billing_not_active': 0,
'critical_provider_error': 0, 'critical_provider_error': 0,
'timeout': 0 'timeout': 0,
'other_errors': []
} }
input_tokens = 0 input_tokens = 0
@ -168,6 +169,11 @@ async def respond(
output_tokens = client_json_response['usage']['completion_tokens'] output_tokens = client_json_response['usage']['completion_tokens']
server_json_response = client_json_response server_json_response = client_json_response
elif response.content_type == 'text/plain':
data = (await response.read()).decode("utf-8")
print(f'[!] {data}')
skipped_errors['other_errors'] = skipped_errors['other_errors'].append(data)
continue
if is_stream: if is_stream:
input_tokens = await count_tokens_for_messages(payload['messages'], model=model) input_tokens = await count_tokens_for_messages(payload['messages'], model=model)
@ -205,7 +211,8 @@ async def respond(
continue continue
else: else:
skipped_errors = {k: v for k, v in skipped_errors.items() if v > 0} skipped_errors = {k: v for k, v in skipped_errors.items() if ((isinstance(v, int) and v > 0) or
(isinstance(v, list) and len(v) > 0))}
skipped_errors = ujson.dumps(skipped_errors, indent=4) skipped_errors = ujson.dumps(skipped_errors, indent=4)
yield await errors.yield_error(500, yield await errors.yield_error(500,
f'Sorry, our API seems to have issues connecting to "{model}".', f'Sorry, our API seems to have issues connecting to "{model}".',
@ -216,7 +223,6 @@ async def respond(
if (not is_stream) and server_json_response: if (not is_stream) and server_json_response:
yield json.dumps(server_json_response) yield json.dumps(server_json_response)
role = user.get('role', 'default') role = user.get('role', 'default')
model_multipliers = config['costs'] model_multipliers = config['costs']