Coverage

streaQ

Fast, async, fully-typed distributed task queue via Redis streams

Features

Up to 14x faster than arq
Fully typed
Comprehensive documentation
Support for delayed/scheduled tasks
Cron jobs
Task middleware
Task dependency graph
Pipelining
Priority queues
Support for synchronous tasks (run in separate threads)
Redis Sentinel & Cluster support for production
Built-in web UI for monitoring tasks
Built with structured concurrency on anyio, supports both asyncio and trio

[!TIP] Sick of redis-py? Check out coredis, a fast, fully-typed Redis client that supports Trio!

Installation

$ pip install streaq

Getting started

To start, you'll need to create a Worker object:

from streaq import Worker

worker = Worker(redis_url="redis://localhost:6379", anyio_backend="trio")

You can then register async tasks with the worker like this:

import trio

@worker.task
async def sleeper(time: int) -> int:
    await trio.sleep(time)
    return time

@worker.cron("* * * * mon-fri")  # every minute on weekdays
async def cronjob() -> None:
    print("Nobody respects the spammish repetition!")

Finally, let's use the worker's async context manager to queue up some tasks:

async with worker:
    await sleeper.enqueue(3)
    # enqueue returns a task object that can be used to get results/info
    task = await sleeper.enqueue(1).start(delay=3)
    print(await task.info())
    print(await task.result(timeout=5))

Putting this all together gives us example.py. Let's spin up a worker:

$ streaq run example:worker

and queue up some tasks like so:

$ python example.py

Let's see what the output looks like:

[INFO] 2025-09-23 02:14:30: starting worker 3265311d for 2 functions
[INFO] 2025-09-23 02:14:35: task sleeper □ cf0c55387a214320bd23e8987283a562 → worker 3265311d
[INFO] 2025-09-23 02:14:38: task sleeper ■ cf0c55387a214320bd23e8987283a562 ← 3
[INFO] 2025-09-23 02:14:40: task sleeper □ 1de3f192ee4a40d4884ebf303874681c → worker 3265311d
[INFO] 2025-09-23 02:14:41: task sleeper ■ 1de3f192ee4a40d4884ebf303874681c ← 1
[INFO] 2025-09-23 02:15:00: task cronjob □ 2a4b864e5ecd4fc99979a92f5db3a6e0 → worker 3265311d
Nobody respects the spammish repetition!
[INFO] 2025-09-23 02:15:00: task cronjob ■ 2a4b864e5ecd4fc99979a92f5db3a6e0 ← None

TaskInfo(fn_name='sleeper', enqueue_time=1751508876961, tries=0, scheduled=datetime.datetime(2025, 7, 3, 2, 14, 39, 961000, tzinfo=datetime.timezone.utc), dependencies=set(), dependents=set())
TaskResult(fn_name='sleeper', enqueue_time=1751508876961, success=True, start_time=1751508880500, finish_time=1751508881503, tries=1, worker_id='ca5bd9eb', _result=1)

For more examples, check out the documentation.

Metadata

Release files for streaq 7.2.0

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

Source distribution (sdist)

Source distribution for streaq 7.2.0
File	Size	Uploaded
streaq-7.2.0.tar.gz	36.5 kB	Sep 3, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for streaq 7.2.0
File	Interpreter	ABI	Platform	Reset
streaq-7.2.0-py3-none-any.whl 43.7 kB Sep 3, 2026	Python 3	none	any	Details

Total release size: 80.3 kB

Release files / streaq-7.2.0.tar.gz

Download URL	streaq-7.2.0.tar.gz
Size	36.5 kB
Tags	Source
SHA-256 checksum How to use checksums	`d34a1419b7d19a0c99c64e8925eff818a394a8abc25d3604aa7a389b08b6dff4`
BLAKE2b-256 checksum How to use checksums	`6d4dd8081b30f38fad8b69c6c86328a4e5f04aa0e556cb2629521ffb82eea26f`
Upload date	Sep 3, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`uv/0.12.9 {"installer":{"name":"uv","version":"0.12.9","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 / streaq-7.2.0-py3-none-any.whl

Download URL	streaq-7.2.0-py3-none-any.whl
Size	43.7 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`9d246bc0a75960c089feb341ae49c3ce629ce9efa6748b3749a2ae5ca682f997`
BLAKE2b-256 checksum How to use checksums	`85dbc2e865fd75e6f49be5766ab02d604ebc0767c0938b961423cb248108202c`
Upload date	Sep 3, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`uv/0.12.9 {"installer":{"name":"uv","version":"0.12.9","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}`