ask/kombu — Issue #104: Celery Cam Crashing
Author: kevinpostal
Created: 2012-02-23 10:25:43+00:00
State: open

was running

/usr/bin/python manage.py celerycam

Here is Trace back:

Traceback (most recent call last):
File "manage.py", line 11, in
execute_manager(settings)
File "/usr/local/lib/python2.6/dist-packages/django/core/management/__init__.py", line 438, in execute_manager
utility.execute()
File "/usr/local/lib/python2.6/dist-packages/django/core/management/__init__.py", line 379, in execute
self.fetch_command(subcommand).run_from_argv(self.argv)
File "/usr/local/lib/python2.6/dist-packages/django/core/management/base.py", line 191, in run_from_argv
self.execute(*args, **options.__dict__)
File "/usr/local/lib/python2.6/dist-packages/djcelery/management/base.py", line 25, in execute
super(CeleryCommand, self).execute(*args, **options)
File "/usr/local/lib/python2.6/dist-packages/django/core/management/base.py", line 220, in execute
output = self.handle(*args, **options)
File "/usr/local/lib/python2.6/dist-packages/djcelery/management/commands/celerycam.py", line 26, in handle
ev.run(*args, **options)
File "/usr/local/lib/python2.6/dist-packages/celery/bin/celeryev.py", line 35, in run
detach=detach)
File "/usr/local/lib/python2.6/dist-packages/celery/bin/celeryev.py", line 67, in run_evcam
return cam()
File "/usr/local/lib/python2.6/dist-packages/celery/events/snapshot.py", line 115, in evcam
recv.capture(limit=None)
File "/usr/local/lib/python2.6/dist-packages/celery/events/__init__.py", line 207, in capture
list(self.itercapture(limit=limit, timeout=timeout, wakeup=wakeup))
File "/usr/local/lib/python2.6/dist-packages/celery/events/__init__.py", line 194, in itercapture
self.wakeup_workers(channel=consumer.channel)
File "/usr/local/lib/python2.6/dist-packages/celery/events/__init__.py", line 212, in wakeup_workers
channel=channel)
File "/usr/local/lib/python2.6/dist-packages/celery/task/control.py", line 230, in broadcast
channel=channel)
File "/usr/lib/python2.6/contextlib.py", line 34, in __exit__
self.gen.throw(type, value, traceback)
File "/usr/local/lib/python2.6/dist-packages/celery/app/base.py", line 281, in default_connection
yield connection
File "/usr/local/lib/python2.6/dist-packages/celery/task/control.py", line 230, in broadcast
channel=channel)
File "/home/code/filterfoundry/kombu/pidbox.py", line 229, in _broadcast
channel=chan)
File "/home/code/filterfoundry/kombu/pidbox.py", line 204, in _publish
producer.publish(message)
File "/home/code/filterfoundry/kombu/messaging.py", line 162, in publish
return publish(message, routing_key, mandatory, immediate, exchange)
File "/home/code/filterfoundry/kombu/entity.py", line 214, in publish
immediate=immediate)
File "/home/code/filterfoundry/kombu/transport/virtual/__init__.py", line 432, in basic_publish
exchange, routing_key, **kwargs)
File "/home/code/filterfoundry/kombu/transport/virtual/exchange.py", line 126, in deliver
self.channel._put_fanout(exchange, message, **kwargs)
File "/home/code/filterfoundry/kombu/transport/SQS.py", line 223, in _put_fanout
self._put(route["queue"], message, **kwargs)
File "/home/code/filterfoundry/kombu/transport/SQS.py", line 215, in _put
q = self._new_queue(queue)
File "/home/code/filterfoundry/kombu/transport/SQS.py", line 166, in _new_queue
self.entity_name(queue),
File "/home/code/filterfoundry/kombu/transport/SQS.py", line 157, in entity_name
return safe_str(name).translate(table)
TypeError: expected a character buffer object