Setting Time Limit on specific task with celery

by

You can set task time limits (hard and/or soft) either while defining a task or while calling.

from celery.exceptions import SoftTimeLimitExceeded

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

or 

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

Leave a Comment