Traceback (most recent call last):


 "/usr/local/lib/python3.6/site-packages/urllib3/connection.py", line 141, in _new_conn

(self.host, self.port), self.timeout, **extra_kw)


 "/usr/local/lib/python3.6/site-packages/urllib3/util/connection.py", line 83, in create_connection

raise err


 "/usr/local/lib/python3.6/site-packages/urllib3/util/connection.py", line 73, in create_connection

sock.connect(sa)
ConnectionRefusedError: [Errno 111] Connection refused

Traceback (most recent call last):


 "example.py", line 41, in <module>

main()


 "example.py", line 37, in main

sig.apply_async(queue='my_queue')


 "/usr/local/lib/python2.7/site-packages/celery/canvas.py", line 235, in apply_async

return _apply(args, kwargs, **options)


 "/usr/local/lib/python2.7/site-packages/celery/app/task.py", line 570, in apply_async

**options


 "/usr/local/lib/python2.7/site-packages/celery/app/base.py", line 741, in send_task

amqp.send_task_message(P, name, message, **options)


 "/usr/local/lib/python2.7/site-packages/kombu/utils/objects.py", line 44, in __get__

value = obj.__dict__[self.__name__] = self.__get(obj)


 "/usr/local/lib/python2.7/site-packages/celery/app/amqp.py", line 264, in send_task_message

return self._create_task_sender()


 "/usr/local/lib/python2.7/site-packages/celery/app/amqp.py", line 477, in _create_task_sender

default_queue = self.default_queue


 "/usr/local/lib/python2.7/site-packages/kombu/utils/objects.py", line 44, in __get__

value = obj.__dict__[self.__name__] = self.__get(obj)


 "/usr/local/lib/python2.7/site-packages/celery/app/amqp.py", line 596, in default_queue

return self.queues[self.app.conf.task_default_queue]


 "/usr/local/lib/python2.7/site-packages/celery/app/amqp.py", line 90, in __getitem__

return dict.__getitem__(self, name)


 "/usr/local/lib/python2.7/site-packages/celery/app/amqp.py", line 102, in __missing__

raise KeyError(name)
KeyError: None
