Skip to content

Instantly share code, notes, and snippets.

@faraocious
faraocious / chain_runner.py
Last active August 29, 2015 13:58
Exploration of Celery Issue #1671
from celerydemo.chain_tasks import a, b, c
from celery import *
## BASE CASE
a.apply_async()
b.apply_async()
c.apply_async()
## BASE CHAIN CASE
chain(a.si())()
wrapper.retry(max_retries=max_retries, countdown=countdown, exc=exc)
AttributeError: 'function' object has no attribute 'retry'