Skip to content

Inbox Failure

  • Back to Testing Overview

    Return to the Testing overview page with all topics.

    Back to Overview

A handler error leaves the inbox row NOT_PROCESSED. flush_counter is 1.

See Using the transactional inbox.

await harness.inbox.add([("msg-2", CreateOrder(sku="book"))])
await harness.inbox.process_available()
row = harness.inbox.one("msg-2")
assert row.status is cqrs.InboxStatus.NOT_PROCESSED
assert row.flush_counter == 1

Library example: examples/testing/outbox_inbox.py.