using raw events for records and responses

main.py

@@ -15,11 +15,15 @@ for webhook in client.webhooks:
     webhook.delete()
 
 # Create a webhook for record events
-@rg.webhook_listener(events=["record.created", "record.updated", "record.completed"])
-async def record_events(record: rg.Record, **kwargs):
-    print(f"Received event {kwargs['type']} for record {record.id}")
 
-    incoming_events.put(record)
+@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)
+
+    incoming_events.put(event)
 
 # Create a webhook for dataset events
 @rg.webhook_listener(events=["dataset.created", "dataset.updated", "dataset.published"])
@@ -30,11 +34,14 @@ async def dataset_events(type: str, dataset: rg.Dataset | None = None, **kwargs)
 
 
 # Create a webhook for response events
-@rg.webhook_listener(events=["response.created", "response.updated"])
-async def response_events(response: rg.UserResponse, **kwargs):
-    print(f"Received event {kwargs['type']} for response {response.id}")
-
-    incoming_events.put(response)
+@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)
+
+    incoming_events.put(event)
 
 @rg.webhook_listener(events=["record.deleted", "dataset.deleted", "response.deleted"])
 async def deleted_events(type: str, data: dict, **kwargs):