我知道这违背了使用 Celery 的全部目的,但是是否有一个函数会阻塞直到结果返回?
所以我可以调用 actual_result = MyTask.dont_delay(some_arg="foo")
这将阻止并只返回结果?
最佳答案
AsyncResult.get 阻塞直到任务准备好,并返回它的结果:
http://ask.github.com/celery/reference/celery.result.html#celery.result.AsyncResult.get
result = MyTask.delay(some_arg="foo")
result.get()
关于celery - celery 延迟的阻塞版本?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10158084/