Update app.py

app.py

@@ -143,10 +143,11 @@ async def update_validation_space_on_answer(response, type, timestamp):
         # Store the error in the queue for display
         incoming_events.put({"event": "error", "error": str(e)})
 
-# Function to read the next event from the queue
+# Function to read the next event from the queue and update UI elements
 def read_next_event():
     if not incoming_events.empty():
-        return incoming_events.get()
+        event = incoming_events.get()
+        return event
     return {}
 
 # Function to get the current annotation progress data
@@ -424,16 +425,16 @@ with gr.Blocks(theme=gr.themes.Soft(primary_hue="pink", secondary_hue="purple"))
             return annotation_progress[code]
         return {}
 
-    # Set up event handlers
-    event_update = gr.on(
-        triggers=[read_next_event],
-        fn=lambda event: (
-            event,  # Update events JSON
-            update_map() if event.get("event") == "progress_update" else None,  # Update map
-            update_stats() if event.get("event") == "progress_update" else (None, None, None),  # Update stats
-        ),
-        outputs=[events_json, map_html, total_docs, avg_completion, countries_over_50]
-    )
+    # Simple event processing functions for better compatibility
+    def update_events():
+        return read_next_event()
+        
+    def update_all_stats():
+        return update_stats()
+    
+    # Use separate timers for each component for better compatibility
+    gr.Timer(1, active=True).tick(update_events, outputs=events_json)
+    gr.Timer(5, active=True).tick(update_all_stats, outputs=[total_docs, avg_completion, countries_over_50])
     
     country_selector.change(
         fn=update_country_details,
@@ -441,9 +442,11 @@ with gr.Blocks(theme=gr.themes.Soft(primary_hue="pink", secondary_hue="purple"))
         outputs=[country_progress]
     )
     
-    # Update everything every 10 seconds
-    gr.Timer(10, active=True).tick(
-        update_map,
+    # Use refresh button instead of timer for map updates (more compatible across versions)
+    refresh_btn = gr.Button("Refresh Map")
+    refresh_btn.click(
+        fn=update_map,
+        inputs=None,
         outputs=[map_html]
     )