如果在一定时间内没有执行,如何为任务设置时间限制,然后只需在芹菜中将其删除
How to set a time limit to a task if not excute within a certain time then just remove it in celery
我正在使用celery(rabbitmq as broker)做很多任务,每个任务minute.Since任务有点耗时,队列中的任务可能会累积导致最新的任务无法执行及时。我该如何处理?
我想我在文档中找到了它:
add.apply_async(args=[10, 10], expires=60)
@task(expires=50)
我正在使用celery(rabbitmq as broker)做很多任务,每个任务minute.Since任务有点耗时,队列中的任务可能会累积导致最新的任务无法执行及时。我该如何处理?
我想我在文档中找到了它:
add.apply_async(args=[10, 10], expires=60)
@task(expires=50)