asyncio fix

app.py

@@ -85,18 +85,22 @@ async def listen_to_alerts(r):
                 for entry_id, entry_data in new_entries:
                     description, entry_dict = await create_textual_description(entry_data)
                     await save({"content": description, "metadata": entry_dict})
-                    st.toast(description, icon='🔔')
                     # Update the last ID read
                     last_id = entry_id
+                    st.toast(description, icon='🔔')
     except KeyboardInterrupt:
         print("Exiting...")
 
 # Start Redis listener in a separate thread
 def start_redis_listener():
     try:
-        asyncio.run(listen_to_alerts(r))
+        loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)
+        loop.run_until_complete(listen_to_alerts(r))
     except Exception as e:
         print(f"Error in Redis listener: {e}")
+    finally:
+        loop.close()
 
 # Streamlit Application
 st.set_page_config(