芹菜过期涨价例外

Question

在文档中link关于过期

# Task expires after one minute from now.
add.apply_async(args=[10, 10], expires=60) 

我使用：

^{pr2}$

在任务.py在

from celery.task import task
@task
def add(x, y):
    return x + y

芹菜：

[2012-03-21 19:50:03,012: WARNING/MainProcess] Skipping revoked task: tasks.add[4ffcff91-b12b-4bce-8d47-159314759859]

在控制台中：

4ffcff91-b12b-4bce-8d47-159314759859
True

Traceback (most recent call last):
  File "/home/echeg/Dropbox/my_py/opoveshun/tests/celery/run_task.py", line 53, in <module>
    tr.countdown()
  File "/home/echeg/Dropbox/my_py/opoveshun/tests/celery/run_task.py", line 26, in countdown
    self.printus(result)
  File "/home/echeg/Dropbox/my_py/opoveshun/tests/celery/run_task.py", line 48, in printus
    print (result.get())  # Waits until the task is done and returns the retval.
  File "/usr/local/lib/python2.7/dist-packages/celery/result.py", line 95, in get
    interval=interval)
  File "/usr/local/lib/python2.7/dist-packages/celery/backends/amqp.py", line 144, in wait_for
    raise self.exception_to_python(meta["result"])
celery.exceptions.TaskRevokedError

为什么我会有例外？结果尚未过期

如果我使用：

result = add.apply_async(args=[10, 10])

一切都好

226107de-f739-4860-83bc-d843f17a257e
False
None
20
20
True

Answer 1

celeryd认为您的任务已过期：

[2012-03-21 19:50:03,012: WARNING/MainProcess] Skipping revoked task: tasks.add[4ffcff91-b12b-4bce-8d47-159314759859]

当一个过期的任务被一个工作线程拾取时，it revokes it不执行。检查你的时区设置？我遇到了一个相反的问题：任务没有在应该到期的时候过期。这帮我解决了这个问题：

^{2}$