Update app.py

app.py

@@ -54,7 +54,7 @@ async def stream_response(response_text: str):
     words = response_text.split()
     for i in range(0, len(words), 2):
         chunk = " ".join(words[i:i+2]) + " "
-        yield f"data: {json.dumps({
+        chunk_data = {
             'id': f'chatcmpl-{os.urandom(12).hex()}',
             'object': 'chat.completion.chunk',
             'created': int(time.time()),
@@ -64,11 +64,12 @@ async def stream_response(response_text: str):
                 'delta': {'content': chunk},
                 'finish_reason': None
             }]
-        }, ensure_ascii=False)}\n\n"
+        }
+        yield f"data: {json.dumps(chunk_data, ensure_ascii=False)}\n\n"
         await asyncio.sleep(0.1)  # Небольшая задержка между чанками
     
     # Отправляем финальное сообщение
-    yield f"data: {json.dumps({
+    final_data = {
         'id': f'chatcmpl-{os.urandom(12).hex()}',
         'object': 'chat.completion.chunk',
         'created': int(time.time()),
@@ -78,7 +79,8 @@ async def stream_response(response_text: str):
             'delta': {},
             'finish_reason': 'stop'
         }]
-    }, ensure_ascii=False)}\n\n"
+    }
+    yield f"data: {json.dumps(final_data, ensure_ascii=False)}\n\n"
 
 @app.get("/")
 async def root():