python - celery 中的递归任务

Question

我想使用 Celery 编写这样的任务:

@celery.task
def add_task():
    ....
    if(condition):
        add_task.apply_async(queue="default")

我知道在 python 中，调用递归函数时存在最大深度。这个限制也适用于 celery 吗？

Answer 1

这应该没有任何问题。

但是，如果 add_task 取决于子任务的结果，您可能会遇到工作人员用完的问题，但从您的小片段来看似乎并非如此。从技术上讲，您可以排队的任务数量是有限制的，因为您最终会耗尽内存。

您最好尝试一下，看看会发生什么!