[Bugfix] Fix asyncio.Task not being subscriptable (#4623)

This commit is contained in:
Cyrus Leung 2024-05-07 00:31:05 +08:00 committed by GitHub
parent 0650e5935b
commit 323f27b904
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 5 deletions

View File

@ -1,8 +1,8 @@
import asyncio import asyncio
import time import time
from functools import partial from functools import partial
from typing import (Any, AsyncIterator, Callable, Dict, Iterable, List, from typing import (AsyncIterator, Callable, Dict, Iterable, List, Optional,
Optional, Set, Tuple, Type, Union) Set, Tuple, Type, Union)
from transformers import PreTrainedTokenizer from transformers import PreTrainedTokenizer
@ -327,7 +327,7 @@ class AsyncLLMEngine:
# We need to keep a reference to unshielded # We need to keep a reference to unshielded
# task as well to prevent it from being garbage # task as well to prevent it from being garbage
# collected # collected
self._background_loop_unshielded: Optional[asyncio.Task[Any]] = None self._background_loop_unshielded: Optional[asyncio.Task] = None
self.start_engine_loop = start_engine_loop self.start_engine_loop = start_engine_loop
self._errored_with: Optional[BaseException] = None self._errored_with: Optional[BaseException] = None

View File

@ -4,7 +4,7 @@ import inspect
import re import re
from contextlib import asynccontextmanager from contextlib import asynccontextmanager
from http import HTTPStatus from http import HTTPStatus
from typing import Any, Set from typing import Set
import fastapi import fastapi
import uvicorn import uvicorn
@ -34,7 +34,7 @@ openai_serving_chat: OpenAIServingChat
openai_serving_completion: OpenAIServingCompletion openai_serving_completion: OpenAIServingCompletion
logger = init_logger(__name__) logger = init_logger(__name__)
_running_tasks: Set[asyncio.Task[Any]] = set() _running_tasks: Set[asyncio.Task] = set()
@asynccontextmanager @asynccontextmanager