celery - 使用 celery 设置特定任务的时间限制

Question

我在 Celery 中有一个任务，正常运行时可能会运行 10,000 秒。然而，我所有其余的任务应该在一秒钟之内完成。如何为故意长时间运行的任务设置时间限制而不更改短期运行任务的时间限制？

Answer 1

您可以在定义任务或调用时设置任务时间限制( hard 和/或 soft )。

from celery.exceptions import SoftTimeLimitExceeded

@celery.task(time_limit=20)
def mytask():
    try:
        return do_work()
    except SoftTimeLimitExceeded:
        cleanup_in_a_hurry()

或

mytask.apply_async(args=[], kwargs={}, time_limit=30, soft_time_limit=10)