Merge 6ba39b421c into 401bf3a8a7

api.py

@@ -2,6 +2,7 @@ from fastapi import FastAPI, Request
 from transformers import AutoTokenizer, AutoModel
 import uvicorn, json, datetime
 import torch
+import asyncio
 
 DEVICE = "cuda"
 DEVICE_ID = "0"
@@ -29,24 +30,28 @@ async def create_item(request: Request):
     max_length = json_post_list.get('max_length')
     top_p = json_post_list.get('top_p')
     temperature = json_post_list.get('temperature')
-    response, history = model.chat(tokenizer,
+
-                                   prompt,
+    def _sync_chat(history):
-                                   history=history,
+        response, history = model.chat(tokenizer,
-                                   max_length=max_length if max_length else 2048,
+                                       prompt,
-                                   top_p=top_p if top_p else 0.7,
+                                       history=history,
-                                   temperature=temperature if temperature else 0.95)
+                                       max_length=max_length if max_length else 2048,
-    now = datetime.datetime.now()
+                                       top_p=top_p if top_p else 0.7,
-    time = now.strftime("%Y-%m-%d %H:%M:%S")
+                                       temperature=temperature if temperature else 0.95)
-    answer = {
+        now = datetime.datetime.now()
-        "response": response,
+        time = now.strftime("%Y-%m-%d %H:%M:%S")
-        "history": history,
+        answer = {
-        "status": 200,
+            "response": response,
-        "time": time
+            "history": history,
-    }
+            "status": 200,
-    log = "[" + time + "] " + '", prompt:"' + prompt + '", response:"' + repr(response) + '"'
+            "time": time
-    print(log)
+        }
-    torch_gc()
+        log = "[" + time + "] " + '", prompt:"' + prompt + '", response:"' + repr(response) + '"'
-    return answer
+        print(log)
+        torch_gc()
+        return answer
+
+    return await asyncio.to_thread(_sync_chat, history=history)
 
 
 if __name__ == '__main__':