diff --git a/common/concurrency.py b/common/concurrency.py index 675fbf1..c1eefc6 100644 --- a/common/concurrency.py +++ b/common/concurrency.py @@ -36,10 +36,6 @@ async def iterate_in_threadpool(generator: Generator) -> AsyncGenerator: break -def release_semaphore(): - generate_semaphore.release() - - async def generate_with_semaphore(generator: Union[AsyncGenerator, Generator]): """Generate with a semaphore.""" diff --git a/common/networking.py b/common/networking.py index 58702d6..47ebe06 100644 --- a/common/networking.py +++ b/common/networking.py @@ -8,8 +8,6 @@ from loguru import logger from pydantic import BaseModel from typing import Optional -from common.concurrency import release_semaphore - class TabbyRequestErrorMessage(BaseModel): """Common request error type.""" @@ -53,7 +51,6 @@ def handle_request_error(message: str, exc_info: bool = True): def handle_request_disconnect(message: str): """Wrapper for handling for request disconnection.""" - release_semaphore() logger.error(message)