mirror of
https://github.com/NovaOSS/nova-api.git
synced 2024-11-29 10:43:57 +01:00
Compare commits
1 commit
007e078fb6
...
3389892e12
Author | SHA1 | Date | |
---|---|---|---|
3389892e12 |
|
@ -7,6 +7,7 @@ import aiohttp
|
||||||
import asyncio
|
import asyncio
|
||||||
import starlette
|
import starlette
|
||||||
|
|
||||||
|
from typing import Any, Coroutine, Set
|
||||||
from rich import print
|
from rich import print
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
|
|
||||||
|
@ -23,6 +24,19 @@ CRITICAL_API_ERRORS = ['invalid_api_key', 'account_deactivated']
|
||||||
|
|
||||||
keymanager = providerkeys.manager
|
keymanager = providerkeys.manager
|
||||||
|
|
||||||
|
background_tasks: Set[asyncio.Task[Any]] = set()
|
||||||
|
|
||||||
|
|
||||||
|
def create_background_task(coro: Coroutine[Any, Any, Any]) -> None:
|
||||||
|
"""asyncio.create_task, which prevents the task from being garbage collected.
|
||||||
|
|
||||||
|
https://docs.python.org/3/library/asyncio-task.html#asyncio.create_task
|
||||||
|
"""
|
||||||
|
task = asyncio.create_task(coro)
|
||||||
|
background_tasks.add(task)
|
||||||
|
task.add_done_callback(background_tasks.discard)
|
||||||
|
|
||||||
|
|
||||||
async def respond(
|
async def respond(
|
||||||
path: str='/v1/chat/completions',
|
path: str='/v1/chat/completions',
|
||||||
user: dict=None,
|
user: dict=None,
|
||||||
|
@ -172,7 +186,7 @@ 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)
|
||||||
|
|
||||||
asyncio.create_task(
|
create_background_task(
|
||||||
after_request.after_request(
|
after_request.after_request(
|
||||||
incoming_request=incoming_request,
|
incoming_request=incoming_request,
|
||||||
target_request=target_request,
|
target_request=target_request,
|
||||||
|
|
Loading…
Reference in a new issue