sqlalchemy-foundation-kit

Async SQLAlchemy session management, base ORM models with UUIDs and UTC timestamps, AsyncSession lifecycle wired to a Unit of Work.

redis-client-kit

redis-py wrapper with optional Pydantic serialization and OpenTelemetry spans on every command.

aiokafka-foundation-kit

asyncio Kafka producer/consumer abstraction over aiokafka with structured logging and metrics.

omni-box

Transactional Outbox and Inbox patterns — write events in the same DB transaction as your business data, publish to Kafka asynchronously, consume idempotently.

idempotency-kit

Idempotency key guards for HTTP endpoints and Kafka consumers — at-most-once semantics where you need them.

deadline-budget

Deadline and budget propagation across async task chains so no task runs longer than it should.

alembic-gauntlet

Stairway tests for Alembic migrations — every upgrade and downgrade, in order, against a real database.

pg-partsmith

PostgreSQL declarative table partitioning helpers for SQLAlchemy projects.