EDRI

EDRI is a Python framework for building event-driven, parallel, and distributed applications. It combines messaging, task execution, and an optional API layer (REST, WebSocket, HTML) into a single coherent system.

Why EDRI?

Most Python frameworks solve one problem well:

Celery handles background tasks but has no API layer or pub/sub.
Kafka streams messages but does not execute tasks.
FastAPI builds APIs but lacks task distribution.

EDRI combines all three: message routing, task execution, and API exposure in one framework.

Quick start

pip install edri[uvicorn]

# main.py
from edri import EDRI
from edri.abstract import ManagerBase, request
from edri.dataclass.event import Event
from edri.dataclass.response import Response, response
from edri.api.dataclass.api_event import api
from http import HTTPMethod


@response
class HelloResponse(Response):
    message: str

@api(url="/hello/{name}", method=HTTPMethod.GET)
class Hello(Event):
    name: str
    response: HelloResponse

class HelloManager(ManagerBase):
    @request
    def greet(self, event: Hello) -> None:
        event.response.message = f"Hello, {event.name}!"

if __name__ == "__main__":
    edri = EDRI()
    edri.add_component(HelloManager(edri.router_queue))
    edri.start_api()
    edri.run()

python main.py &
curl -H "Accept: application/json" http://localhost:8080/hello/World

Full getting-started guide: Getting Started

Architecture overview

Events are the universal communication primitive. The Router dispatches them by type to subscribed Managers. Managers can delegate work to Workers (threads or processes), emit new events, or use specialized components like the Scheduler (timed events) and Key-Value Store (shared state). The API layer translates external HTTP/WS requests into events. For distributed deployments, the Switch connects routers across machines via TCP/IP.

Installation

# Core: Router, Managers, Workers, Switch, Scheduler, Store
pip install edri

# HTTP/WebSocket API, with an ASGI server
pip install edri[uvicorn]    # recommended
pip install edri[hypercorn]  # HTTP/3 support
pip install edri[daphne]     # Twisted-based

# API layer without an ASGI server (e.g. behind edri[grpc])
pip install edri[api]

# Development
pip install edri[dev]

Requirements

Python 3.12+
POSIX OS (Linux, macOS — macOS has never been tested)

Getting Started

If you're new to EDRI, start here:

Getting Started — installation, minimal example, next steps
Architecture — component model, process architecture, data flow
Testing — unit and integration testing guide

Core Concepts

Event — defining events, responses, field types, lifecycle
Response — response status, directives, HTTP status mapping
Router — dispatching, subscriptions, caching, health checks
Manager — event handlers, workers, lifecycle, caching
Worker — thread vs process, communication, event_send

API Layer

API — REST, WebSocket, HTML, content negotiation
API Event — @api(...) decorator, URL patterns, input extraction
Content Negotiation — Accept header handling, response wrapping, Vary
Download — Path vs SharedMemoryPipe, HTTP Range
HTML — Jinja2 templates, {% url %}, static files
WebSocket — connection, commands, subscription protocol
Validation — inject(...), built-in validators, custom validators
Uploads — file upload lifecycle, temporary files, workers, cleanup responsibility
Middleware — pipeline, auth patterns, transport-agnostic design
Broker — client management, WebSocket subscription trie, middleware execution

Distribution

Connector — Router ↔ Switch bridge, demands, resilience
Switch — TCP/IP hub, message protocol, connection lifecycle

Specialized Components

Specialized Managers — timed events, shared state
Watcher — hot-reload for development
JSON Encoder — custom JSON serialization
Utility — Storage, Queue, NormalizedDefaultDict

Operations

Environment — all configuration variables
Deployment — production setup, Docker, Nginx, systemd, Kubernetes
Troubleshooting — common problems, diagnostics, gotchas
Versioned Documentation — how the /vX.Y.Z/, /stable/ and version switcher work

Examples

Example	Area	Documentation
REST CRUD with validation	REST	REST CRUD
HTML form Post/Redirect/Get	HTML	HTML Form
CPU-bound WorkerProcess	Worker	CPU Bound
Streaming ZIP via SharedMemoryPipe	Worker	SharedMemoryPipe
Periodic refresh + Store	Scheduler	Periodic Refresh
WebSocket ticket pattern	WebSocket	WebSocket Upload
Bearer token authentication	Middleware	Auth Middleware

Quick comparison with other frameworks

Feature	EDRI	Celery	Kafka	FastAPI
Task execution	✅ Built-in	✅ Workers	❌ Messaging only	❌
API layer	✅ REST/WS/HTML	❌	❌	✅ REST/WS
Pub/Sub	✅ Static routing	❌	✅ Dynamic	⚠️ WS only
Middleware	✅ Full pipeline	❌	❌	✅ DI
Distributed	✅ Via Switch	✅ Brokers	✅ Clusters	❌
Parallelism	✅ Threads + processes	✅ Workers	⚠️ Consumers	⚠️ Async

License

MIT License.

Author

Marek Olšan (marek@olsanovi.cz)

Metadata

Release files for edri 2026.9.3

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for edri 2026.9.3
File	Size	Uploaded
edri-2026.9.3.tar.gz	312.0 kB	Oct 1, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for edri 2026.9.3
File	Interpreter	ABI	Platform	Reset
edri-2026.9.3-py3-none-any.whl 366.9 kB Oct 1, 2026	Python 3	none	any	Details

Total release size: 679.0 kB

Release files / edri-2026.9.3.tar.gz

Download URL	edri-2026.9.3.tar.gz
Size	312.0 kB
Tags	Source
SHA-256 checksum How to use checksums	`559123600ce64a6fb43027efbe05bcd3194d7fdb34895c7c379e4bc8bea555f2`
BLAKE2b-256 checksum How to use checksums	`70af192df11a4a54a46c93485528d2d5e33dc5440452c26ce619416339e9fb95`
Upload date	Oct 1, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.2.0 CPython/3.13.15`

Release files / edri-2026.9.3-py3-none-any.whl

Download URL	edri-2026.9.3-py3-none-any.whl
Size	366.9 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`96a118d57185364383801634fcc5f2fce99feb2172c6974c71bbf0e0b207e2d2`
BLAKE2b-256 checksum How to use checksums	`e054f1aa40a9b29284c11e0dd3c60818a8c1871f6e63f3f667e66aedf69c32ce`
Upload date	Oct 1, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.2.0 CPython/3.13.15`