Đặt giới hạn thời gian cho một nhiệm vụ cụ thể với cần tây

Question

Tôi có một nhiệm vụ trong Celery có khả năng chạy trong 10.000 giây trong khi hoạt động bình thường. Tuy nhiên, tất cả các nhiệm vụ còn lại của tôi sẽ được thực hiện trong chưa đầy một giây. Làm thế nào tôi có thể đặt giới hạn thời gian cho tác vụ cố ý chạy dài mà không thay đổi giới hạn thời gian đối với các tác vụ chạy ngắn?

Answer 1

Bạn có thể đặt giới hạn thời gian tác vụ (hard và/hoặc soft) trong khi xác định tác vụ hoặc trong khi gọi.

from celery.exceptions import SoftTimeLimitExceeded 

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

hoặc

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

Answer 2

Đây là một ví dụ với trang trí cho một công tác cụ thể và cần tây 3.1.23 sử dụng 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