セロリで特定のタスクに時間制限を設定する

Question

セロリで正常に動作している間に10,000秒間実行される可能性のあるタスクがあります。しかし、残りの作業はすべて1秒未満で完了しなければなりません。短時間実行するタスクの時間制限を変更せずに、意図的に長時間実行しているタスクの時間制限を設定するにはどうすればよいですか？

Answer 1

タスクの定義中または呼び出し中に、タスクの時間制限（hardおよび/またはsoft）を設定できます。

from celery.exceptions import SoftTimeLimitExceeded 

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

又は

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

Answer 2

これは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