2

我对最新版本的 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

有人可以帮我吗?

4

1 回答 1

0

我将队列的名称从 base_s1 更改为 root_s1,现在一切正常..

于 2013-06-08T14:04:07.667 回答