Update app.py

app.py

@@ -19,6 +19,16 @@ def restart_script_periodically():
 restart_thread = Thread(target=restart_script_periodically, daemon=True)
 restart_thread.start()
 
+def reset_queue_periodically():
+    start_time = time.time()
+    while True:
+        if time.time() - start_time >= 120: # 5 minutes
+            queue.queue.clear()
+            start_time = time.time()
+
+reset_queue_thread = Thread(target=reset_queue_periodically, daemon=True)
+reset_queue_thread.start()
+
 queue = Queue()
 queue_threshold = 50