celery_task_with_time_limits.py

@app.task(soft_time_limit=5, time_limit=10)
def time_limited_task():
    """
    This task has time limits to ensure it will never work for
    longer than anticipated.

    soft_time_limit is a number of seconds when SoftTimeLimitExceeded
    is raised to give a moment to clean up.
    time_limit is a number of seconds after task is terminated unconditionally
    """
    will_sleep_for = randint(5, 15)
    logger.info(f'Work started (need {will_sleep_for}s to finish)')
    try:
        sleep(will_sleep_for)
    except SoftTimeLimitExceeded:
        logger.info('Oups, soft limit exceeded! Quickly, clean up!')
        sleep(will_sleep_for)