我对最新版本的 celery (3.0.19) 有疑问。我有非常简单的任务:
@celery.task()
def last_uid():
return 100
我执行它
uid = last_uid.apply_async(None, queue='base_s1').get(timeout=4)
一切似乎都正常,但芹菜有时会失去这个任务。这是芹菜日志 - http://pastebin.com/4ePbiFdf
有人可以帮我吗?
我对最新版本的 celery (3.0.19) 有疑问。我有非常简单的任务:
@celery.task()
def last_uid():
return 100
我执行它
uid = last_uid.apply_async(None, queue='base_s1').get(timeout=4)
一切似乎都正常,但芹菜有时会失去这个任务。这是芹菜日志 - http://pastebin.com/4ePbiFdf
有人可以帮我吗?