Impostazione del limite di tempo per attività specifiche con il sedano

Question

Ho un'attività in Celery che potrebbe potenzialmente funzionare per 10.000 secondi mentre funziona normalmente. Comunque tutto il resto dei miei compiti dovrebbe essere fatto in meno di un secondo. Come posso impostare un limite di tempo per l'attività intenzionalmente lunga durata senza modificare il limite di tempo per le attività di breve durata?

Answer 1

È possibile impostare i limiti di tempo di attività (hard e/o soft) durante la definizione di un'attività o durante la chiamata.

from celery.exceptions import SoftTimeLimitExceeded 

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

o

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

Answer 2

Questo è un esempio di un decoratore specifica attività e sedano 3.1.23 usando soft_time_limit = 10000

@task(bind=True, default_retry_delay=30, max_retries=3, soft_time_limit=10000) 
def process_task(self, task_instance): 
    """Task processing.""" 
     pass