refactor: Show queue elements one by one

main.py

@@ -9,22 +9,16 @@ client = rg.Argilla()
 server = rg.get_webhook_server()
 incoming_events = Queue()
 
-# Set up the webhook listeners
 
-# Delete all existing webhooks
-for webhook in client.webhooks:
-    webhook.delete()
+# Set up the webhook listeners
 
 # Create a webhook for record events
 
-@rg.webhook_listener(
-    events=["record.created", "record.updated", "record.completed"],
-    raw_event=True # Using raw events until PR https://github.com/argilla-io/argilla/pull/5500 is merged
-)
-async def record_events(event:dict):
-    print("Received event", event)
+@rg.webhook_listener(events=["record.created", "record.updated", "record.completed"])
+async def record_events(record: rg.Record, type: str, **kwargs):
+    print("Received event", type)
 
-    incoming_events.put(event)
+    incoming_events.put(record)
 
 # Create a webhook for dataset events
 @rg.webhook_listener(events=["dataset.created", "dataset.updated", "dataset.published"])
@@ -34,15 +28,14 @@ async def dataset_events(type: str, dataset: rg.Dataset | None = None, **kwargs)
     incoming_events.put((type, dataset))
 
 
+
 # Create a webhook for response events
-@rg.webhook_listener(
-    events=["response.created", "response.updated"],
-    raw_event=True # Using raw events until PR https://github.com/argilla-io/argilla/pull/5500 is merged
-)
-async def response_events(event: dict):
-    print("Received event", event)
+@rg.webhook_listener(events=["response.created", "response.updated"])
+async def response_events(response: rg.UserResponse, type:str, **kwargs):
+    print("Received event type", type)
+
+    incoming_events.put(response)
 
-    incoming_events.put(event)
 
 @rg.webhook_listener(events=["record.deleted", "dataset.deleted", "response.deleted"])
 async def deleted_events(type: str, data: dict, **kwargs):
@@ -50,24 +43,21 @@ async def deleted_events(type: str, data: dict, **kwargs):
 
     incoming_events.put((type, data))
 
+
 def check_incoming_events():
     """
     This function is called every 5 seconds to check if there are any incoming
     events and send data to update the JSON component.
     """
-    events = []
-    while not incoming_events.empty():
-        events.append(incoming_events.get())
-
-    return {"events": events}
+    event = incoming_events.get()
 
+    return event
 
 with gr.Blocks() as demo:
     argilla_server = client.http_client.base_url
     gr.Markdown("## Argilla Events")
     gr.Markdown(f"This demo shows the incoming events from the [Argilla Server]({argilla_server}).")
     json_component = gr.JSON(label="Incoming argilla events:")
-    gr.Timer(5, active=True).tick(check_incoming_events, outputs=json_component)
-
+    gr.Timer(1, active=True).tick(check_incoming_events, outputs=json_component)
 
 gr.mount_gradio_app(server, demo, path="/")