我有使用django项目与celery + rabbitmq，我的一些任务需要像6小时或更多，甚至堆栈，所以我想重新运行相同的任务，如果它需要超过6小时如何做到这一点，我新的celery ？
lkaoscv71#
你可以试试;
from celery.exceptions import SoftTimeLimitExceeded @celery.task(soft_time_limit=60*60*6) # <--- Set time limit to 6 hours def mytask(): try: return do_work() except SoftTimeLimitExceeded: mytask.retry() # <--- Retry task after limit of 6 hours exceeded
1条答案
按热度按时间lkaoscv71#
你可以试试;