Dramatiq middleware to abort tasks.
Project description
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)
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
dramatiq-abort-1.1.0.tar.gz
(14.5 kB
view hashes)
Built Distribution
Close
Hashes for dramatiq_abort-1.1.0-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 597eef7c0cbf99de36c8bec0a7b766547081eb3a12e586d9e4f034e1ba547bec |
|
| MD5 | d58c67af55556150ec0557f8ee60feb4 |
|
| BLAKE2b-256 | 2281a9a64883baa2d8ab11aa576c70ef90324bfec6ab48746eaf56945bb7a5ae |
