У кого-то еще есть проблемы с поддержанием работы ghettoq на заднем плане с django-сельдереем?

Question

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

Хорошо обрабатывает один запрос, затем клиентское приложение, отправляющее следующее задание в очереди, завершается с этим отслеживанием.

   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'

Мы переключаемся на rabbitMQ, так как он "... просто работает«

Answer 1

Переключение на RabbitMQ, вероятно, хорошая идея.Но обратите внимание, что эта ошибка исправлена ​​в основной ветке ghettoq.