Сельдерей AsyncResult с Redis BackendResult Странное поведение - PullRequest
0 голосов
/ 14 мая 2018

Я выполнил асинхронную задачу с сельдереем; Я использую Redis в качестве Backend и 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

Что я делаю не так?

1 Ответ

0 голосов
/ 14 мая 2018

Глупый я; -)

мой сельдерей был настроен на сохранение результатов 5 секунд ...

app.conf.update(result_expires=5,)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...