[AIRFLOW-3502] Add celery config option for setting "pool" (#4308)

apache · Dec 12, 2018 · 96b8db6 · 96b8db6
1 parent e9a09d4
commit 96b8db6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/airflow/bin/cli.py b/airflow/bin/cli.py
@@ -1052,6 +1052,9 @@ def worker(args):
         'loglevel': conf.get('core', 'LOGGING_LEVEL'),
     }
 
+    if conf.has_option("celery", "pool"):
+        options["pool"] = conf.get("celery", "pool")
+
     if args.daemon:
         pid, stdout, stderr, log_file = setup_locations("worker",
                                                         args.pid,