fix: restore queue_worker export in server.py, fix RESPONSE_COMPLETION_TIMEOUT import

Author: maebahesioru

src/api/app.py

@@ -158,7 +158,7 @@ async def _shutdown_resources():
 async def lifespan(app: FastAPI):
     """FastAPI application life cycle management"""
     import server
-    from server import queue_worker
+    from api import queue_worker
     original_streams = (sys.stdout, sys.stderr)
     initial_stdout, initial_stderr = _setup_logging()
     logger = server.logger

src/api/queue_worker.py

@@ -205,11 +205,11 @@ async def non_streaming_disconnect_monitor():
 
                         try:
                             if completion_event:
-                                from server import RESPONSE_COMPLETION_TIMEOUT
+                                from config import RESPONSE_COMPLETION_TIMEOUT
                                 await asyncio.wait_for(completion_event.wait(), timeout=RESPONSE_COMPLETION_TIMEOUT / 1000 + 60)
                                 logger.info(f'[{req_id}] (Worker) ✅ 流式生成器完成信号收到。客户端提前断开: {client_disconnected_early}')
                             else:
-                                from server import RESPONSE_COMPLETION_TIMEOUT
+                                from config import RESPONSE_COMPLETION_TIMEOUT
                                 await asyncio.wait_for(asyncio.shield(result_future), timeout=RESPONSE_COMPLETION_TIMEOUT / 1000 + 60)
                                 logger.info(f'[{req_id}] (Worker) ✅ 非流式处理完成。客户端提前断开: {client_disconnected_early}')
 

src/server.py

@@ -11,7 +11,7 @@
 from playwright.async_api import Page as AsyncPage, Browser as AsyncBrowser, Playwright as AsyncPlaywright
 from config import *
 from models import WebSocketConnectionManager
-from api import create_app
+from api import create_app, queue_worker
 
 STREAM_QUEUE: Optional[multiprocessing.Queue] = None
 STREAM_PROCESS = None