Async Runner
Project description
Async Runner
Async runner is a thin wrapper over Celery API. This will enable control over failed messages by moving them to separate queue (generally queue_name_error) and also allows to retry the task with the help of retry policy.
More can be found at documentation: https://async_runner.readthedocs.org
from async_runner import async_runner
async_runner.send_task(
task_fn=func, # task function can be python module path
queue='queue_name', # name of the queue
args=(arg1, arg2, arg3, ), # tuple/list of positional arguments to task function
kwargs={'name': 'parameter'}, # dictionary with key word arguments to task function
options={
'max_retries': 3, # maximum number of times the task is retried
'retry_policy': {
'retry_interval': 12 # interval between retires (in seconds)
}
}
)
TODO: Decouple from Django
History
0.1.0 (2016-1-22)
First release on PyPI.
0.1.1 (2016-1-22)
Fix issues.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
async_runner-0.1.2.tar.gz
(13.6 kB
view hashes)
Built Distribution
Close
Hashes for async_runner-0.1.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2f88387cacbde4d7ace128351ce61720e66b55164852d66debde00f4c5773416 |
|
MD5 | 74c77f9e2a2bc7ed621808ee1f083b87 |
|
BLAKE2b-256 | 2cf4580e8c85b55988b896841638b619b03e610953d1f76ec1a10a5ebc77dbc5 |