Tunning celery settings to avoid reserved (as in stuck) tasks

apache · Jan 13, 2015 · 8bd122f · 8bd122f
1 parent 9c10e12
commit 8bd122f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py
@@ -17,10 +17,11 @@
 
 
 class CeleryConfig(object):
-    BROKER_URL = conf.get('celery', 'BROKER_URL')
-    CELERY_RESULT_BACKEND = conf.get('celery', 'CELERY_RESULT_BACKEND')
     CELERY_ACCEPT_CONTENT = ['json', 'pickle']
     CELERYD_PREFETCH_MULTIPLIER = 1
+    CELERY_ACKS_LATE = True
+    BROKER_URL = conf.get('celery', 'BROKER_URL')
+    CELERY_RESULT_BACKEND = conf.get('celery', 'CELERY_RESULT_BACKEND')
     CELERYD_CONCURRENCY = int(conf.get('celery', 'CELERYD_CONCURRENCY'))
 
 app = Celery(