使用allow_join_result。请参见下面的代码段。
@app.task(ignore_result=True)
def catpure_res(task_id):
task_obj = AsyncResult(task_id)
with allow_join_result():
task_obj.get(on_message=on_msg)
注意：如其他答案中所述，它可能导致性能问题甚至死锁，但是如果您的任务写得好并且没有引起意外的错误，则它应该像魅力一样工作。
602392714
清零编程群