Update controllers/ws_controller.py

controllers/ws_controller.py

@@ -55,7 +55,7 @@ def get_messages(code: str,websocket:WebSocket,brand_name: Optional[str] = None)
         print(gmail_data)
         
         if "messages" in gmail_data:
-            with ThreadPoolExecutor(max_workers=15) as executor:
+            with ThreadPoolExecutor(max_workers=5) as executor:
                 for message_data in gmail_data["messages"]:
                            
                     executor.submit(fetch_message_wrapper, message_data , websocket) 
@@ -77,8 +77,10 @@ def get_messages(code: str,websocket:WebSocket,brand_name: Optional[str] = None)
     return messages
 
 async def process_message(message:Message, websocket:WebSocket, chunk_size:int):
+    logging.info("process_message")
     if message:
         message_json = message.to_json()
+        logging.info(f"{message_json}")
         await send_message_in_chunks(websocket, message_json, chunk_size)
         await websocket.send_text("NEXT_MESSAGE")