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.
1 maintainer
Metadata
1 maintainer
Release files for async_runner 0.1.7
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | Provenance | |
|---|---|---|---|---|
| async_runner-0.1.7.tar.gz | 14.3 kB | Without provenance | Details |
Release files / async_runner-0.1.7.tar.gz
| Download URL | async_runner-0.1.7.tar.gz |
|---|---|
| Size | 14.3 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
e5e61b29b43448f8efdf2a74ac52b8f9ca25f97ad730f1e5257d7e33638088bb
|
|
BLAKE2b-256 checksum How to use checksums |
7c1fca981a8fa0e31b1262076c4105d8eb216c17b62063745afdc2d2a6de1cf7
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
Security for async_runner 0.1.7
Provenance
Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.
No provenance found
None of the files in this release were uploaded with provenance metadata.
A note on package security
PyPI is a repository for distributing packages, not a service for auditing them. While third-party security researchers and our staff do their best to detect and remove malicious packages, PyPI cannot guarantee the quality, security or suitability of any given package.
