Skip to main content

Async Runner

Project description

Async Runner Documentation Status

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:

from async_runner import async_runner
    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
        '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


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.

Files for async_runner, version 0.1.7
Filename, size File type Python version Upload date Hashes
Filename, size async_runner-0.1.7.tar.gz (14.3 kB) File type Source Python version None Upload date Hashes View

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring DigiCert DigiCert EV certificate Facebook / Instagram Facebook / Instagram PSF Sponsor Fastly Fastly CDN Google Google Object Storage and Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Salesforce Salesforce PSF Sponsor Sentry Sentry Error logging StatusPage StatusPage Status page