I have a Django application installed that submits tasks to Celery, and there is the following in my settings.py file:
BROKER_HOST = "localhost" BROKER_PORT = 5672 BROKER_USER = "user" BROKER_PASSWORD = "password" BROKER_VHOST = "host" BROKER_BACKEND = "amqp" ... CELERY_ALWAYS_EAGER = False
I start the server and everything seems fine until I go to complete the task. I get the following error:
Exception Type: KeyError Exception Value: 'No such transport: amqp'
I have the AMQP library installed and listed in my package sites directory, but I canβt find anything about this error ...?
source share