Update app.py

app.py

@@ -34,7 +34,6 @@ async def echo(websocket):
             return
         m = data["message"]
         token = data["token"]
-        userData = json.load(open("userData.json", "w"))
         docs = retriever.get_relevant_documents(m)
         userData[token]["docs"] = str(docs)
         response = conversational_rag_chain.invoke(
@@ -49,8 +48,6 @@ async def main():
     async with serve(echo, "0.0.0.0", 7860):
         await asyncio.Future()
 
-asyncio.run(main())
-
 if not os.path.isdir('database'):
     os.system("unzip database.zip")
 
@@ -150,6 +147,7 @@ conversational_rag_chain = RunnableWithMessageHistory(
     output_messages_key="answer",
 )
 
+asyncio.run(main())
 """
 websocket
 streamlit app ~> backend