refactor logging mechanism in run_concurrent_tasks to use get_session_logs

app/app.py

@@ -103,9 +103,10 @@ async def start_chat():
 
 async def run_concurrent_tasks(llm, message):
     asyncio.create_task(llm.acomplete(message))
+    asyncio.create_task(_logger.distribute())
     # Stream logger output while LLM is running
-    while True:
-        async for chunk in _logger.pop(llm.session_id):
+    while True:        
+        async for chunk in _logger.get_session_logs(llm.session_id):
             yield chunk  # Yield each chunk directly
 
 @cl.on_message