Add setting to control request interruption

Author: abetlen

llama_cpp/server/app.py

@@ -85,6 +85,10 @@ class Settings(BaseSettings):
     port: int = Field(
         default=8000, description="Listen port"
     )
+    interrupt_requests: bool = Field(
+        default=True,
+        description="Whether to interrupt requests when a new request is received.",
+    )
 
 
 router = APIRouter()
@@ -379,7 +383,7 @@ async def event_publisher(inner_send_chan: MemoryObjectSendStream):
                         await inner_send_chan.send(dict(data=json.dumps(chunk)))
                         if await request.is_disconnected():
                             raise anyio.get_cancelled_exc_class()()
-                        if llama_outer_lock.locked():
+                        if settings.interrupt_requests and llama_outer_lock.locked():
                             await inner_send_chan.send(dict(data="[DONE]"))
                             raise anyio.get_cancelled_exc_class()()
                     await inner_send_chan.send(dict(data="[DONE]"))
@@ -486,6 +490,7 @@ async def create_chat_completion(
     request: Request,
     body: CreateChatCompletionRequest,
     llama: llama_cpp.Llama = Depends(get_llama),
+    settings: Settings = Depends(get_settings),
 ) -> Union[llama_cpp.ChatCompletion, EventSourceResponse]:
     exclude = {
         "n",
@@ -511,7 +516,7 @@ async def event_publisher(inner_send_chan: MemoryObjectSendStream):
                         await inner_send_chan.send(dict(data=json.dumps(chat_chunk)))
                         if await request.is_disconnected():
                             raise anyio.get_cancelled_exc_class()()
-                        if llama_outer_lock.locked():
+                        if settings.interrupt_requests and llama_outer_lock.locked():
                             await inner_send_chan.send(dict(data="[DONE]"))
                             raise anyio.get_cancelled_exc_class()()
                     await inner_send_chan.send(dict(data="[DONE]"))