You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2016/05/31 07:04:07 UTC

incubator-airflow git commit: [AIRFLOW-25] Configuration for Celery always required

Repository: incubator-airflow
Updated Branches:
  refs/heads/master 767849226 -> 03e8e5d49


[AIRFLOW-25] Configuration for Celery always required

Dear Airflow Maintainers,

Please accept this PR that addresses the following issues:
- AIRFLOW-25

For now, if airflow.cfg has no [celery] section, all subcommands fail.
This patch adds the default values for Celery-related properties
as well as existing 'default_queue' and 'flower_port',
so as to make all subcommands work and suppress "not found in config"
warnings even if [celery] section is omitted.

Author: Kengo Seki <se...@apache.org>

Closes #1558 from sekikn/AIRFLOW-25.


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/03e8e5d4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/03e8e5d4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/03e8e5d4

Branch: refs/heads/master
Commit: 03e8e5d49f2539057574daecd3f1711e666c29e9
Parents: 7678492
Author: Kengo Seki <se...@apache.org>
Authored: Tue May 31 09:03:54 2016 +0200
Committer: Bolke de Bruin <bo...@xs4all.nl>
Committed: Tue May 31 09:03:54 2016 +0200

----------------------------------------------------------------------
 airflow/configuration.py | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/03e8e5d4/airflow/configuration.py
----------------------------------------------------------------------
diff --git a/airflow/configuration.py b/airflow/configuration.py
index 582bc7c..a7d62ca 100644
--- a/airflow/configuration.py
+++ b/airflow/configuration.py
@@ -135,8 +135,13 @@ defaults = {
         'max_threads': 2,
     },
     'celery': {
+        'broker_url': 'sqla+mysql://airflow:airflow@localhost:3306/airflow',
+        'celery_app_name': 'airflow.executors.celery_executor',
+        'celery_result_backend': 'db+mysql://airflow:airflow@localhost:3306/airflow',
+        'celeryd_concurrency': 16,
         'default_queue': 'default',
-        'flower_port': '5555'
+        'flower_port': '5555',
+        'worker_log_server_port': '8793',
     },
     'email': {
         'email_backend': 'airflow.utils.email.send_email_smtp',