Anyone else having trouble keeping ghettoq running inthe background with django-celery?

Question

nohup python manage.py celeryd -f queue.log 2>queue.err 1>queue.out &

Handles one request fine, then the client app posting the next job to the queues fails with this traceback.

   tasks.spawn_job.delay(details)

 File "/releases/env/lib/python2.6/site-packages/celery/task/base.py", line 321, in delay
   return self.apply_async(args, kwargs)

 File "/releases/env/lib/python2.6/site-packages/celery/task/base.py", line 337, in apply_async
   return apply_async(self, args, kwargs, **options)

 File "/releases/env/lib/python2.6/site-packages/celery/messaging.py", line 248, in _inner
   return fun(*args, **kwargs)

 File "/releases/env/lib/python2.6/site-packages/celery/execute/__init__.py", line 101, in apply_async
   publisher or publish.close()

 File "/releases/env/lib/python2.6/site-packages/carrot/messaging.py", line 766, in close
   self.backend.close()

 File "/releases/env/lib/python2.6/site-packages/ghettoq/taproot.py", line 188, in close
   for consumer_tag in self._t.consumers.keys():

AttributeError: 'thread._local' object has no attribute 'consumers'

We are switching to rabbitMQ, since it "...just works"

Answer 1

Switching to RabbitMQ is probably a good idea. But note that this is a bug fixed in the master branch of ghettoq.