python - 如何在 celery 中回调但不阻止进程

Question

现在我有一些大任务，它们都是由一些小任务组成的，我将它们放入代理中，当一个大任务的所有小任务完成时，我将需要一个回调来处理结果这些小任务我知道 celery 有原始和弦，只要我有一项大任务就可以做到，但我有很多任务所以，如果我这样写:

chord([task11.s(),task12.s()])(mycallback.s()).get()
chord([task21.s(),task22.s()])(mycallback.s()).get()

第一条线完成后，第二条线才会开始，但这样，有些 worker 就会成为偶像很长一段时间，这是不好的，那么 celery 中是否有一些方法可以在某些条件发生时回调，但不会阻止进程？

==================================================

apply_async 有效!@Gigapalmer，谢谢您的帮助

Answer 1

尝试链接异步方法，以便当一个方法完成时，您可以使用 apply_async 和所需参数调用链中的下一个方法，从技术上讲，这将创建一个新作业(应该位于不同的队列上)。