1
我试图重试失败,下面的代码一个任务:芹菜 - 任务重试导致奇怪的错误
@task(bind=True)
def update_listing(self, listing_object, retailer):
try:
listing = _update_listing(listing_object, retailer)
except Exception as exc:
raise self.retry(exc=exc)
return listing
这导致以下错误被抛出:
Reject: (TypeError('__init__() takes exactly 2 arguments (3 given)',), True)
我可以这个错误与什么有关,或者我如何解决它。我是否以正确的方式调用重试方法?
我芹菜配置文件看起来像这样:
BROKER_URL = "redis://localhost:6379/0"
CELERY_IMPORTS = ("tasks",)
CELERY_RESULT_BACKEND = "redis://localhost:6379/0"
CELERY_IGNORE_RESULT = True
编辑:全堆栈跟踪:
Traceback (most recent call last):
File "/home/my-project/venv/local/lib/python2.7/site-packages/celery/app/trace.py", line 218, in trace_task
R = retval = fun(*args, **kwargs)
File "/home/my-project/venv/local/lib/python2.7/site-packages/celery/app/trace.py", line 398, in __protected_call__
return self.run(*args, **kwargs)
File "/home/my-project/tasks.py", line 156, in update_listing
raise self.retry(exc=exc)
File "/home/my-project/venv/local/lib/python2.7/site-packages/celery/app/task.py", line 666, in retry
raise Reject(exc, requeue=True)
Reject: (TypeError('__init__() takes exactly 2 arguments (3 given)',), True)
我使用“应用程序试图“语法,但我仍然遇到同样的问题:( – Hanpan
什么应用语法..我不明白...我说使用'从celery.contrib.methods导入任务'而不是'从芹菜导入任务','或者使用常规函数而不是类内的方法。 – securecurve