如何等到所有的celery任务完成后再继续我的代码？

在使用Celery进行任务调度时，可以通过以下几种方式等待所有的Celery任务完成后再继续执行代码：

使用Celery的AsyncResult对象：在提交任务时，可以获取到每个任务的AsyncResult对象，通过该对象可以获取任务的执行状态和结果。可以使用AsyncResult.ready()方法判断任务是否已经完成，如果任务未完成，则可以使用AsyncResult.get()方法阻塞等待任务完成并获取结果。

from celery.result import AsyncResult

# 提交任务
task_result = my_task.delay()

# 等待任务完成
while not task_result.ready():
    pass

# 获取任务结果
result = task_result.get()

使用Celery的group和chord：group可以将多个任务组合成一个组，chord可以在组内所有任务完成后触发一个回调任务。可以通过AsyncResult对象的chord方法来等待组内所有任务完成。

from celery import group, chord

# 创建任务组
task_group = group([my_task.s() for _ in range(10)])

# 创建回调任务
callback_task = my_callback_task.s()

# 等待任务组完成
result = chord(task_group)(callback_task).get()

使用Celery的AsyncResult对象和wait方法：可以使用AsyncResult对象的wait方法等待多个任务完成。

from celery.result import AsyncResult

# 提交任务
task_results = [my_task.delay() for _ in range(10)]

# 等待任务完成
AsyncResult.wait(task_results)

# 获取任务结果
results = [task_result.get() for task_result in task_results]

以上是几种常见的等待所有Celery任务完成的方法，根据具体的业务需求和代码结构选择合适的方式。关于Celery的更多信息和使用方法，可以参考腾讯云的相关产品文档：腾讯云Celery产品介绍。