Bump version to 0.11.0, update event log docs

on_event callback now receives domain events (event.event_type, event.dataset)
instead of raw (event_type, payload) strings/dicts

Author: koenvo

README.md

@@ -259,10 +259,9 @@ That's it. The `event_log` and `reader_state` tables are created automatically i
 # run_consumer.py
 from ingestify.infra.event_log import EventLogConsumer
 
-def on_event(event_type: str, payload: dict) -> None:
-    if event_type == "revision_added":
-        dataset_id = payload["dataset_id"]
-        # trigger your downstream logic here
+def on_event(event) -> None:
+    if event.event_type == "revision_added":
+        trigger_downstream(event.dataset.dataset_id)
 
 # Run once (e.g. from a cron job):
 EventLogConsumer.from_config("config.yaml", reader_name="my-service").run(on_event)
@@ -271,6 +270,8 @@ EventLogConsumer.from_config("config.yaml", reader_name="my-service").run(on_eve
 EventLogConsumer.from_config("config.yaml", reader_name="my-service").run(on_event, poll_interval=5)
 ```
 
+`on_event` receives a domain event with `event.event_type` and `event.dataset`. Available event types: `dataset_created`, `revision_added`, `metadata_updated`.
+
 `from_config` reads `metadata_url` from your existing `config.yaml` — no duplicate connection strings.
 
 `run()` returns `0` on success and `1` if a processing error occurred. On error the cursor is **not** advanced, so the failing event will be retried on the next run.

docs/configuration.md

@@ -189,9 +189,9 @@ Write a small script (run as a cron job or long-running process) that reads from
 ```python
 from ingestify.infra.event_log import EventLogConsumer
 
-def on_event(event_type: str, payload: dict) -> None:
-    if event_type == "revision_added":
-        trigger_downstream(payload["dataset_id"])
+def on_event(event) -> None:
+    if event.event_type == "revision_added":
+        trigger_downstream(event.dataset.dataset_id)
 
 # Run once (cron-friendly, exits 0 on success or 1 on error):
 EventLogConsumer.from_config("config.yaml", reader_name="my-service").run(on_event)

ingestify/__init__.py

@@ -9,4 +9,4 @@
     from .source_base import Source, DatasetResource
     from .main import debug_source
 
-__version__ = "0.10.0"
+__version__ = "0.11.0"