Skip to main content

Async Runner

Project description

Async Runner

https://img.shields.io/pypi/v/async_runner.svg https://img.shields.io/travis/vedarthk/async_runner.svg 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: 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.7.tar.gz (14.3 kB view hashes)

Uploaded Source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page