repid

Repid is a simple, fast, and extensible async task queue framework, with built-in AsyncAPI 3.0 schema generation.

pip install repid

Features

AsyncAPI 3.0 out of the box - your schema is generated automatically as you build. No separate spec files to maintain, no drift between code and docs.
Broker flexibility - works with RabbitMQ, Redis, AWS SQS, Kafka, NATS, and Google Cloud Pub/Sub. Switch or run multiple brokers side by side without changing your actor code.
Extreme performance - built for maximum throughput and minimal overhead, making it the fastest async task queue in the Python ecosystem.
Developer ergonomics - define actors as plain async functions with dependency injection and Pydantic argument validation.
Built for testability - a drop-in TestClient lets you test actors in-memory without a running broker, making unit tests fast and dependency-free.
LLM-friendly documentation - grab llms.txt or llms-full.txt from the docs site to feed into your favorite AI coding assistant.

Quickstart

Here is how the simplest producer-consumer application looks, using AMQP server.

Producer:

import asyncio

from repid import AmqpServer, Repid

app = Repid(title="My App", version="1.0.0")
app.servers.register_server(
    "default",
    AmqpServer("amqp://user:password@localhost:5672"),
    is_default=True,
)


async def main() -> None:
    async with app.servers.default.connection():
        await app.send_message(
            channel="default",
            payload=b"",
            headers={"topic": "awesome_job"},
        )


asyncio.run(main())

Consumer:

import asyncio

from repid import AmqpServer, Repid, Router

app = Repid(title="My App", version="1.0.0")
app.servers.register_server(
    "default",
    AmqpServer("amqp://user:password@localhost:5672"),
    is_default=True,
)

router = Router()


@router.actor
async def awesome_job() -> None:
    print("Hello async jobs!")
    await asyncio.sleep(1.0)


app.include_router(router)


async def main() -> None:
    async with app.servers.default.connection():
        await app.run_worker()


asyncio.run(main())

Check out user guide to learn more!

License

Repid is distributed under the terms of the MIT license. Please see License.md for more information.

Repid's logo is distributed under the terms of the CC BY-NC 4.0 license. It is originally created by ari_the_crow_.

Release files for repid 2.2.0a1

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

Source distribution (sdist)

Source distribution for repid 2.2.0a1
File	Size	Uploaded
repid-2.2.0a1.tar.gz	596.6 kB	Sep 14, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for repid 2.2.0a1
File	Interpreter	ABI	Platform	Reset
repid-2.2.0a1-py3-none-any.whl 218.3 kB Sep 14, 2026	Python 3	none	any	Details

Total release size: 814.9 kB

Release files / repid-2.2.0a1.tar.gz

Download URL	repid-2.2.0a1.tar.gz
Size	596.6 kB
Tags	Source
SHA-256 checksum How to use checksums	`b0d09f0440a4bcaf661d1a0ee925ac60f8980bcf8bb2c2b6040df0c66da522f1`
BLAKE2b-256 checksum How to use checksums	`0eb89a0823cdce4eb71e816ed093768ddbf286f186069c230b9763134fdfd4b4`
Upload date	Sep 14, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`uv/0.12.13 {"installer":{"name":"uv","version":"0.12.13","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}`

Release files / repid-2.2.0a1-py3-none-any.whl

Download URL	repid-2.2.0a1-py3-none-any.whl
Size	218.3 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`7c1788a2d7f37e903f89932f91f66d855033000b8d945804ddb30b5496be6da3`
BLAKE2b-256 checksum How to use checksums	`5095238d76413ed7b049800d86322c634ff855a6b1b2e906af0bb6f93253a432`
Upload date	Sep 14, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`uv/0.12.13 {"installer":{"name":"uv","version":"0.12.13","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}`