我有最新版本的芹菜(3.0.19)的问题。我有一个很简单的任务:
@celery.task()
def last_uid():
return 100
i execute by
uid = last_uid.apply_async(None, queue='base_s1').get(timeout=4)
一切似乎都工作,但芹菜有时失去了这个任务。这是芹菜日志- http://pastebin.com/4ePbiFdf
有人能帮我吗?
我将队列名称从base_s1更改为root_s1,现在一切正常。