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 <sek...@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 <sek...@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',