https://dagster.io/ logo
#announcements
Title
# announcements
s

Shaun Ryan

06/28/2020, 10:40 AM
Hi folks. I'm trying to setup a celery worker. I have rabbit mq with a hostname of rabbitmq. I've set the executor celery url in the $DAGSTER_HOME/pipeline_run.yaml and celery_config.yml as follows: config: -> broker: 'pyamqp://guest:guest@rabbitmq:5672//' starting the broker: dagster-celery worker start -y /opt/dagster/dagster_home/celery_config.yaml However my worker is still looking at localhost and failing to connect 🤔 dagster_worker1_1 | [2020-06-28 103724,256: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.15672// [Errno 111] Connection refused. Am I missing something somewhere?
m

matas

06/28/2020, 1:43 PM
I it not clear from docs but there should be
execution:
celery:
broker: '<pyamqp://guest>:guest@rabbitmq:5672//'
👍 1
s

Shaun Ryan

06/28/2020, 2:04 PM
this is what I got, I'll try with your suggestion - take out config
Top banana... I took the docs literally where hints that it has to be the same as the pipeline_run.yaml Which looks like this: execution: celery: ~*config*~: broker: 'pyamqp://guest:guest@rabbitmq:5672//' Can't argue with the code! Thank you!
3 Views