芹菜异步结果与 Redis 后端结果 奇怪的行为



我用芹菜运行了一个异步任务;我使用 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,)

相关内容

  • 没有找到相关文章

最新更新