我用芹菜运行了一个异步任务;我使用 redis 作为后端和 MessageQueue。
我尝试通过新的 AsyncResult 对象获取存储的结果,但它挂起了。.
我的跑步 :
>>> from test_celery.tasks import add
>>> from celery.result import AsyncResult
>>> r = add.delay(1,1)
>>> r.id
'71bfc569-5752-4535-8a9e-108a80157a1d'
>>> r.backend
<celery.backends.redis.RedisBackend object at 0x7f4242feb0d0>
>>> r.get()
2
>>> r.get()
2
>>> x = AsyncResult(r.id)
>>> x.get()
--> hangs
我做错了什么?
愚蠢的我;-(
我的芹菜设置为保持结果 5 秒......
app.conf.update(result_expires=5,)