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]
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)
Project details
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-0.1b1.tar.gz
(8.3 kB
view hashes)
Built Distribution
Close
Hashes for dramatiq_abort-0.1b1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2c556312531fd517b0b350d7e36d0919e4dcecba9c5c89de8e2e43dbb725878e |
|
MD5 | 5d6ab3c32699e8c8c148bf24b8e02d62 |
|
BLAKE2b-256 | 2ce06ad55963cf9d46c041638131f3896b7107c62807f980264366657ff96d38 |