Software engineering
Stabilize a failing event processor
event_processor.py · illustrative excerpt
# Keep one record per event, even after a retry.
def process(event, store):
return store.insert_once(
event_id=event.id,
payload=event.payload,
)
def test_duplicate_delivery(store):
process(event, store)
process(event, store)
assert store.count(event.id) == 1Example dialogue showing how working context enters the task.
