タスクの1つが失敗した場合、チェーン全体が壊れた場合、セロリチェーンのポイントは何ですか?タスクの1つが失敗した場合、セロリチェーンが破損します
私は、このセロリのチェーンがあります。
res = chain(workme.s (y=1111), workme2.s(2222), workme3.s(3333),)()
をそして私はworkme2は、このような再試行して失敗し作られた:
@celery.task(default_retry_delay=5, max_retries = 10, queue="sure")
def workme2(x,y):
# try:
try:
print str(y)
sleep(2)
print str(x)
## adding any condition that makes the task fail
if x!=None:
raise Exception('Aproblem from your workme task')
print 'This is my username: ' + str(x['user']) + \
' And Password: ' + str(x['pas'])
return "22xx"
except Exception, exc:
workme2.retry(args=[x,y], exc=exc,)
http://stackoverflow.com/questions/11508112/retrying-celery-failed-tasks-that-are-part-of-a-chain –
@BernhardVallant、こんにちは、私は数日前に最新のものをダウンロードしました。このパッチは含まれていませんか? – securecurve
もしそれが3.0.4より新しいなら私はそれが含まれるべきだと思います... –