Re: Airflow 1.8 CeleryExecutor: multiple servers in broker_url

2018-01-17 Thread Andrii Kinash
Hi Fokko, My Celery version is 4.0.2 Thank you for the tip regarding upgrade. Cheers, Andrii > On 17. Jan 2018, at 12:34, Driesprong, Fokko wrote: > > Hi Andrii, > > When looking in the Airflow code, I'd say this should workd: >

Airflow 1.8 CeleryExecutor: multiple servers in broker_url

2018-01-17 Thread Andrii Kinash
Dear Airflow Community, I was able to successfully setup my Celery executor pointing to one RabbitMQ server (broker). However when I’m trying to setup it to point to multiple RabbitMQ servers for HA – it doesn’t seem to work, even thought I’m doing it exactly as it’s written in the Celery

Re: Airflow 1.8 CeleryExecutor: multiple servers in broker_url

2018-01-17 Thread Driesprong, Fokko
Hi Andrii, When looking in the Airflow code, I'd say this should workd: https://github.com/apache/incubator-airflow/blob/v1-8-stable/airflow/executors/celery_executor.py#L41 Which version of celery are you using? Please note, when you are updating to 1.9.1, the config of Celery changes to make