flexiq (Python)

A Rust-powered task queue for Python. No broker required — just SQLite, Postgres, or Redis.

pip install flexiq                # SQLite (default)
pip install flexiq[postgres]      # with Postgres backend

The engine runs in Rust — a Tokio async scheduler, an OS-thread worker pool, and Diesel over SQLite in WAL mode. The GIL is held only during task execution; run --pool prefork for true parallelism on CPU-bound work. Part of the flexiq project (Rust core + native SDKs for Python and Node).

Quickstart

1. Define tasks in tasks.py:

from flexiq import Queue

queue = Queue(db_path="tasks.db")

@queue.task()
def add(a: int, b: int) -> int:
    return a + b

2. Start a worker:

flexiq worker --app tasks:queue

3. Enqueue jobs:

from tasks import add

job = add.delay(2, 3)
print(job.result(timeout=10))  # 5

Features

Each section links to its deep-dive guide. New here? Start with Capabilities at a glance.

Reliability — retries with backoff, per-exception retry rules, soft timeouts, a dead-letter queue with replay, circuit breakers, idempotent enqueue. → guide
Workflows — compose with chain, fan out with group, fan in with chord, plus dependency graphs with cascade cancel. → guide
Concurrency — thread pool by default (I/O-bound); switch to --pool prefork for true CPU parallelism with no GIL contention. → guide
Scheduling — priorities, rate limiting, periodic (cron) tasks, delayed execution, job expiration. → guide
Observability — built-in web dashboard, events, HMAC-signed webhooks, Prometheus + OpenTelemetry exporters, worker heartbeats. → guide
Extensibility — pluggable serializers, per-task middleware, a fully async API, Postgres/Redis backends. → guide

from flexiq import chain, group, chord

# Sequential pipeline — each step receives the previous result
chain(fetch.s(url), parse.s(), store.s()).apply()

# Parallel fan-out, then a callback once all complete
chord([download.s(u) for u in urls], merge.s()).apply()

Integrations

Extra	Install	What you get
Flask	`pip install flexiq[flask]`	`FlexiQ(app)` extension, `flask flexiq worker` CLI
FastAPI	`pip install flexiq[fastapi]`	`FlexiQRouter` for instant REST API over the queue
Django	`pip install flexiq[django]`	Admin integration, management commands
OpenTelemetry	`pip install flexiq[otel]`	Distributed tracing with span-per-task
Prometheus	`pip install flexiq[prometheus]`	`PrometheusMiddleware`, queue depth gauges, `/metrics` server
Sentry	`pip install flexiq[sentry]`	`SentryMiddleware` with auto error capture and task tags
Postgres	`pip install flexiq[postgres]`	Multi-machine workers via PostgreSQL backend
Redis	`pip install flexiq[redis]`	Redis storage backend

Testing

Built-in test mode — no worker needed:

def test_add():
    with queue.test_mode() as results:
        add.delay(2, 3)
        assert results[0].return_value == 5

Documentation

Read the docs → — guides, API reference, and architecture. Coming from Celery? See the Migration Guide. For a project overview and the other SDKs, see the main repository.

License

MIT

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

flexiq-1.0.0.tar.gz (1.7 MB view details)

Uploaded Aug 17, 2026 Source

Built Distributions

If you're not sure about the file name format, learn more about wheel file names.

The dropdown lists show the available interpreters, ABIs, and platforms. Enable javascript to be able to filter the list of wheel files.

flexiq-1.0.0-cp314-cp314-win_amd64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.14Windows x86-64

flexiq-1.0.0-cp314-cp314-musllinux_1_2_x86_64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.14musllinux: musl 1.2+ x86-64

flexiq-1.0.0-cp314-cp314-musllinux_1_2_aarch64.whl (8.3 MB view details)

Uploaded Aug 17, 2026 CPython 3.14musllinux: musl 1.2+ ARM64

flexiq-1.0.0-cp314-cp314-manylinux_2_28_x86_64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.14manylinux: glibc 2.28+ x86-64

flexiq-1.0.0-cp314-cp314-manylinux_2_28_aarch64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.14manylinux: glibc 2.28+ ARM64

flexiq-1.0.0-cp314-cp314-macosx_11_0_arm64.whl (7.6 MB view details)

Uploaded Aug 17, 2026 CPython 3.14macOS 11.0+ ARM64

flexiq-1.0.0-cp314-cp314-macosx_10_12_x86_64.whl (7.4 MB view details)

Uploaded Aug 17, 2026 CPython 3.14macOS 10.12+ x86-64

flexiq-1.0.0-cp313-cp313-win_amd64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.13Windows x86-64

flexiq-1.0.0-cp313-cp313-musllinux_1_2_x86_64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.13musllinux: musl 1.2+ x86-64

flexiq-1.0.0-cp313-cp313-musllinux_1_2_aarch64.whl (8.3 MB view details)

Uploaded Aug 17, 2026 CPython 3.13musllinux: musl 1.2+ ARM64

flexiq-1.0.0-cp313-cp313-manylinux_2_28_x86_64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.13manylinux: glibc 2.28+ x86-64

flexiq-1.0.0-cp313-cp313-manylinux_2_28_aarch64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.13manylinux: glibc 2.28+ ARM64

flexiq-1.0.0-cp313-cp313-macosx_11_0_arm64.whl (7.6 MB view details)

Uploaded Aug 17, 2026 CPython 3.13macOS 11.0+ ARM64

flexiq-1.0.0-cp313-cp313-macosx_10_12_x86_64.whl (7.4 MB view details)

Uploaded Aug 17, 2026 CPython 3.13macOS 10.12+ x86-64

flexiq-1.0.0-cp312-cp312-win_amd64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.12Windows x86-64

flexiq-1.0.0-cp312-cp312-musllinux_1_2_x86_64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.12musllinux: musl 1.2+ x86-64

flexiq-1.0.0-cp312-cp312-musllinux_1_2_aarch64.whl (8.3 MB view details)

Uploaded Aug 17, 2026 CPython 3.12musllinux: musl 1.2+ ARM64

flexiq-1.0.0-cp312-cp312-manylinux_2_28_x86_64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.12manylinux: glibc 2.28+ x86-64

flexiq-1.0.0-cp312-cp312-manylinux_2_28_aarch64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.12manylinux: glibc 2.28+ ARM64

flexiq-1.0.0-cp312-cp312-macosx_11_0_arm64.whl (7.6 MB view details)

Uploaded Aug 17, 2026 CPython 3.12macOS 11.0+ ARM64

flexiq-1.0.0-cp312-cp312-macosx_10_12_x86_64.whl (7.4 MB view details)

Uploaded Aug 17, 2026 CPython 3.12macOS 10.12+ x86-64

flexiq-1.0.0-cp311-cp311-win_amd64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.11Windows x86-64

flexiq-1.0.0-cp311-cp311-musllinux_1_2_x86_64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.11musllinux: musl 1.2+ x86-64

flexiq-1.0.0-cp311-cp311-musllinux_1_2_aarch64.whl (8.3 MB view details)

Uploaded Aug 17, 2026 CPython 3.11musllinux: musl 1.2+ ARM64

flexiq-1.0.0-cp311-cp311-manylinux_2_28_x86_64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.11manylinux: glibc 2.28+ x86-64

flexiq-1.0.0-cp311-cp311-manylinux_2_28_aarch64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.11manylinux: glibc 2.28+ ARM64

flexiq-1.0.0-cp311-cp311-macosx_11_0_arm64.whl (7.6 MB view details)

Uploaded Aug 17, 2026 CPython 3.11macOS 11.0+ ARM64

flexiq-1.0.0-cp311-cp311-macosx_10_12_x86_64.whl (7.4 MB view details)

Uploaded Aug 17, 2026 CPython 3.11macOS 10.12+ x86-64

flexiq-1.0.0-cp310-cp310-win_amd64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.10Windows x86-64

flexiq-1.0.0-cp310-cp310-musllinux_1_2_x86_64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.10musllinux: musl 1.2+ x86-64

flexiq-1.0.0-cp310-cp310-musllinux_1_2_aarch64.whl (8.3 MB view details)

Uploaded Aug 17, 2026 CPython 3.10musllinux: musl 1.2+ ARM64

flexiq-1.0.0-cp310-cp310-manylinux_2_28_x86_64.whl (8.0 MB view details)

Uploaded Aug 17, 2026 CPython 3.10manylinux: glibc 2.28+ x86-64

flexiq-1.0.0-cp310-cp310-manylinux_2_28_aarch64.whl (8.2 MB view details)

Uploaded Aug 17, 2026 CPython 3.10manylinux: glibc 2.28+ ARM64

flexiq-1.0.0-cp310-cp310-macosx_11_0_arm64.whl (7.6 MB view details)

Uploaded Aug 17, 2026 CPython 3.10macOS 11.0+ ARM64

flexiq-1.0.0-cp310-cp310-macosx_10_12_x86_64.whl (7.4 MB view details)

Uploaded Aug 17, 2026 CPython 3.10macOS 10.12+ x86-64

File details

Details for the file flexiq-1.0.0.tar.gz.

File metadata

Download URL: flexiq-1.0.0.tar.gz
Upload date: Aug 17, 2026
Size: 1.7 MB
Tags: Source
Uploaded using Trusted Publishing? Yes
Uploaded via: uv/0.12.5 {"installer":{"name":"uv","version":"0.12.5","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}

File hashes

Hashes for flexiq-1.0.0.tar.gz
Algorithm	Hash digest
SHA256	`4bba1d984da33ecee7139f97fca6480735e69d5a4977785c24dc3796bfcdd16f`
MD5	`81ed15d568c1921a5a9ba1e58361bbaf`
BLAKE2b-256	`0e8481f6141c4d27bfdaaca9c4ca2dd57cd4f6639e1cb9088981ed3dea3b3156`

Algorithm	Hash digest
SHA256	`5367d4aac80c8c6098f0c311bbe110264edcfbf7e5e9890842cc988148e5b492`
MD5	`cd7c3e7fa69d7f566ebbdadc599d935d`
BLAKE2b-256	`ce6a3f760e5c1e1e67891a10659770b9c2735d18be0ed1227fd5c70d9198aae5`

Algorithm	Hash digest
SHA256	`bd3c62a68202c236227d28b0618bcf2d6583f29e0f735ab3f0c0e6bc4d53bfa3`
MD5	`5e93c1948b3d4807a3fd28bd8b49fc6a`
BLAKE2b-256	`bd5ed23abee599a20893b0914bbb0e68240a28cc6d849a6a66463448f9720527`

Algorithm	Hash digest
SHA256	`3ddbca5af3ec56a2f2c40db0bca6f690aa50729e591366bfbb5ca2ba612b5a88`
MD5	`bc69c45d5fccc0d0128564110c0be68b`
BLAKE2b-256	`df82ef5f9e695f87bc97c47c1c73d646af3e09995d025a993c06eca9ad0a9e62`

Algorithm	Hash digest
SHA256	`578ee13bebde58e4ec24fdbcbc51c7defc7e637574171b81be5a201c429e5f2f`
MD5	`079f1d8c1071ea74cde656a85baea976`
BLAKE2b-256	`a07ca1af0805c151e6f14120e7bdbf078463e19bc0ca143cff5da1c8cc2be524`

Algorithm	Hash digest
SHA256	`f3a025c9536fd0869d981219b87e1ab3f43e305236e00f12dc322f19f975d18b`
MD5	`30ddf23c5feedab6820455f5ab117012`
BLAKE2b-256	`c78be949c7759c774f7959fa0b9830744f4c9171e8d204d8bace55d9eac8b09f`

Algorithm	Hash digest
SHA256	`ee0ed86f062d91e2b85f2f60ce7cdbc1d5a40080d962bfa2bce9005e98ab3abc`
MD5	`5e4febd9deb8063232fbda70433282ec`
BLAKE2b-256	`996e39260d352d1d40b700f19572ad4767bee8037bee1dfac4413bbf0c5251f9`

Algorithm	Hash digest
SHA256	`0d89679a028b98caee195c64b8ee53c6bd358600d1cc91cc613e042ab8360436`
MD5	`cd4712916c8796d9fd966e7d500c4d61`
BLAKE2b-256	`8a52bc05719911db74800005c8eb20492ccaf436e757a56a6cb67f1472c7e00f`

Algorithm	Hash digest
SHA256	`48d4ef4916930af3392b8f555e31aa44df43289dfd74e0e82e106f158d94d957`
MD5	`fc2888fd2b5ca10c5e482c23092f0d1c`
BLAKE2b-256	`8cadb977567c1f92a4a5db0de7aebe368dd4c7220f5bb597493643c1ae99866e`

Algorithm	Hash digest
SHA256	`699f3a192a062c87dbee49a88be098d022fdb4a741a14011cd865c2039bd680e`
MD5	`d788b422c665ceb25a635a527822ee63`
BLAKE2b-256	`4c7181d601c049d8d41dc565caf681f1f95059a444e9ba8354b29c6dbaa63456`

Algorithm	Hash digest
SHA256	`586b72fbb8fdeae05446906fed3c00eddbc0b4cab15bcd63ae8cea34308202b3`
MD5	`7d023c995b236b40ea2a0c1448369ddf`
BLAKE2b-256	`ce66712ca6348c6598085d79d7b53aee808724122de606b91583f8c121a9d0bf`

Algorithm	Hash digest
SHA256	`85e8042c8613d998c810efb2ceaa0f883604981db29e0e5f93e3e2b420f0a074`
MD5	`3402b15b05656c61c39ccad9da2fe7c8`
BLAKE2b-256	`973594665453ffe011c73bd010e65540e3d081583c2c771af302a19e8e1064ec`

Algorithm	Hash digest
SHA256	`96aba736a346eb63454df577094a4b8f9e5b178a1b12d9aa703ab07255949e09`
MD5	`4e2fb7c8ee03cc6ce9df6b1678671a80`
BLAKE2b-256	`5c75813160c0009ff7e316167b0c5da1225d1b77ca9288b0c88a4195a91e30da`

Algorithm	Hash digest
SHA256	`de0b7db396666385bceaad58e797b150e28b925c395fa82b51eb13487292127f`
MD5	`e6cd88ff90e1d7b136790825f4f5d50a`
BLAKE2b-256	`f52b85b0368c85083f0d66bde8c1800168758a72c30a9bf5adbc3c59d1c250cf`

Algorithm	Hash digest
SHA256	`822a3b32b3db3f704cafe79b785995300dd46c6bed74a1fcde014576cbf8e47e`
MD5	`b8c8f1c12aa11fec76bc8a46f14706e9`
BLAKE2b-256	`c0b62dae99f595c6865ec952e832a3b276ab1d7e8b6396c18eccdc14206f2fa1`

Algorithm	Hash digest
SHA256	`e38bbdeab1e46ee1ecc34e1c5053f1c78e311db2ffe0b6f0cc2a0c4d7148e59f`
MD5	`7245d11cfc043ec1d952dd151c1893cd`
BLAKE2b-256	`1e8680d949353310894ac0475bceeac8dea146ea51f7e479d17cca8178f27569`

Algorithm	Hash digest
SHA256	`cfe45cc831107ec4308d1b3bbdee35cf241a05c87883e37bfa4646b656f8e88d`
MD5	`7bc9f4572edc553d37e0e3db92d6e635`
BLAKE2b-256	`c77c098a17fd0ddced01b35ca192cb6a831aedb1b01bdd9d11744a32eb5eb72d`

Algorithm	Hash digest
SHA256	`115cda7e2b2a6f91e459c63089d67269376f11e258dcb17cb7109244d32f1d31`
MD5	`b2cbbb9f432d36353d24408ba3d2984d`
BLAKE2b-256	`834f5c6b7dab2533763bf61599d5708dc5080e69d777607696099ea58a89e832`

Algorithm	Hash digest
SHA256	`3d5643e6eb409921e7cedbd5d081b12af48683ea8ac92d662a46a7046fba6696`
MD5	`da28e9cfeccf29ada14ea940cfbedbe7`
BLAKE2b-256	`2bf33713a3877d49c3ce86ff1a822d32ac5875347245e1603296b69c2b84c085`

Algorithm	Hash digest
SHA256	`f7f3bc69f7c6983512812fbbc1131151525df5a29c56004bdb5a62a7b9364551`
MD5	`f6cd16950c9b9b44afb6f2a42e18d41b`
BLAKE2b-256	`759f6c8dfd2ef795104f093ad1053773d0cb084b1a27a0257e20fa3934a14b05`

Algorithm	Hash digest
SHA256	`9f262fe1c0b4deaf9d7804d6ca32a3c08f51080ecb7ddb5fd1d346e0a4aa551e`
MD5	`2652247c3738aac4c08e593613a59cf8`
BLAKE2b-256	`1c8d639422c5b5027cfeac88d08295c91761f5122b30c042cf68c26215bfd554`

flexiq 1.0.0

flexiq (Python)

Quickstart

Features

Integrations

Testing

Documentation

License

Project links

Key dates

1 maintainer

GitHub Statistics

License

Requires

Provides Extra

Classifiers

Download files

Source Distribution

Built Distributions

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

File metadata

File hashes

File details

Algorithm	Hash digest
SHA256	`36ef5642e0777f442067234453dec8c89c1ff4517277d59f5e3f1eaf68c7886e`
MD5	`a56662e5b6947a3ea11d17af5fcfdd4e`
BLAKE2b-256	`f3b2674c46773a2a819dd291844e4a1bf432e1f62dabdd1b48101b00a2007330`

Algorithm	Hash digest
SHA256	`a15aa3697fc2ae04a9d679e0666bfd07becc953e6d2b03a0ea7cec386c31ccca`
MD5	`3cdf22e066f352535fe9f29bfd1265a2`
BLAKE2b-256	`2092e32cbe10e62a8cd4180a1a3016173fb8883b68fb504b14e436fa75d1d78c`

Algorithm	Hash digest
SHA256	`a98ccd38f6001eaff3870a7aabc4ccf6fed7edd3df0cab639b0b0575845ba071`
MD5	`8dcac0897cca11679474ac5cbdf2a932`
BLAKE2b-256	`2d567bc73852e594b3ddc4f4091a770675ac7f3dfbdd6e47667e22a069a95f1a`

Algorithm	Hash digest
SHA256	`c06cfb94a074fea592d1caceed7d13860155556ad7d2b4c50c1c2a67a904da12`
MD5	`40150617653b3910a01a13bf6d0ee15d`
BLAKE2b-256	`4c9c988e92f5f451ed04895be0023f175f88e36f88a39aa93963776148ae89e5`

Algorithm	Hash digest
SHA256	`cc9f884e682dd076a49b482828c7ccd41e53a01d7719231d612db71475ae5a73`
MD5	`653ec148ca20174d4d0bc1b7ab960310`
BLAKE2b-256	`da05e234d790182824a5a3f878012624555232e36b2119e62b360b60287161b4`

Algorithm	Hash digest
SHA256	`336b661590368c89baf927082fc2e10a5a0b6df8c3580fcb6d30fd089a9be3f4`
MD5	`e2df22b4ae1411e5a3dde30ac4e87e1d`
BLAKE2b-256	`dc09a9be85cafcb242591ec59c32cf6ddac43d50d70ecec2cfb4f9c1b98e6fa7`

Algorithm	Hash digest
SHA256	`d32aa4366b5cbf8ef894928d0a80d499b4a0ea1349d590bd8b761eeb5f2760f0`
MD5	`5564e6cf66bedae15617b72d39c9bde0`
BLAKE2b-256	`d925f0b8b3d1c9f02f96b5c1e576246fa01ef73a1c5bff65cc3ebc164a989489`

Algorithm	Hash digest
SHA256	`f3a091e6254def5a3ce1cd6fea0bc42d205f5bdb111068630ece459d7aeaf29b`
MD5	`fdd10d8b849d11d13747719968257bdf`
BLAKE2b-256	`5d37df77db953b67bea77f6ce504690e0714f9827d1655c43acb7571bbdc7177`

Algorithm	Hash digest
SHA256	`d3447beeeac65ddf63be994c076a9148a4b0f46732f1ebf9c0fc4098263d8fc4`
MD5	`c732132a58d9461879106d41bd1593d6`
BLAKE2b-256	`03d90fcaaa49fb5f801193d319d58fbf0a8a7ac294a9d782f6aa937dc72d74b9`

Algorithm	Hash digest
SHA256	`1455519d295fa311818f54f1bcd8f46671e18cf1104d3cc4245cd9e051b3ae0d`
MD5	`bbed82c0a45f5fc6d83522d9b47c02b8`
BLAKE2b-256	`0cda76abf6c4b078b995182ed39663deba0b639e8245d16b94b12c3882f5d996`