docker - Not able to run celery tasks from python shell

Question

I am trying to run celery tasks asynchronously using the .delay() from python shell inside my local machine, The celery uses the rabbitmq as broker and both the celery and rabbitmq servers are running inside 2 different docker containers. The issue here is the celery workers are not connecting to rabbitmq servers

This is the config I'm using here

# celery config
    CELERY_ALWAYS_EAGER = False
    #Default config
    CELERY_BROKER = "amqp://rabbitmq:5672"

    #default config
    CELERY_RESULT_BACKEND = "redis://redis:6379/15"

The docker containers are port mapped to the respective ports of the host machine.

question from:https://stackoverflow.com/questions/65831989/not-able-to-run-celery-tasks-from-python-shell

Answer 1

I think your backend configuration should also be of Rabbitmq. Please try to incorporate the below code for backend. Hope that should help! CELERY_RESULT_BACKEND = ='rpc://'