dramatiq-abort
Add the aborting feature to dramatiq through a simple middleware with flexible backend.
Current version support aborting using the Redis store.
Installation
Since the only available backend right now is Redis:
pip install dramatiq_abort[redis]
Documentation: http://flared.github.io/dramatiq-abort
Quickstart
from dramatiq import get_broker
from dramatiq_abort import Abortable, backends, abort
abortable = Abortable(backend=backends.RedisBackend())
get_broker().add_middleware(abortable)
# ...
import dramatiq
@dramatiq.actor
def my_long_running_task(): ...
message = my_long_running_task.send()
# Now abort the message.
abort(message.message_id)
1 maintainer
Release files for dramatiq-abort 1.2.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| dramatiq_abort-1.2.1.tar.gz | 15.7 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| dramatiq_abort-1.2.1-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 28.5 kB
Release files / dramatiq_abort-1.2.1.tar.gz
| Download URL | dramatiq_abort-1.2.1.tar.gz |
|---|---|
| Size | 15.7 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
795ee9a37d884d70e63b758031017cd1f7c33f40db5f4901aaa95fcb659c13c0
|
|
BLAKE2b-256 checksum How to use checksums |
bcc764363acb81ea0df7e230efc1e04daf34c6e26ce59d0fd3bafff39b558c73
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/5.1.1 CPython/3.9.20
|
Release files / dramatiq_abort-1.2.1-py3-none-any.whl
| Download URL | dramatiq_abort-1.2.1-py3-none-any.whl |
|---|---|
| Size | 12.8 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
d025e358875b437346cc2f665525735b1a079ce7dcac9c3dc70853fa798efd69
|
|
BLAKE2b-256 checksum How to use checksums |
5d7c44815003095e842cc2917cdbc6b690603f984903559a26bffc23682fa0f9
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/5.1.1 CPython/3.9.20
|
