celeryd startup crash

[vbabiy]

Crash with this exception:

./manage.py celeryd
/var/lib/python-support/python2.6/MySQLdb/__init__.py:34: DeprecationWarning: the sets module is deprecated
  from sets import ImmutableSet
Celery 0.3.20 is starting.
Configuration ->
    * Broker -> amqp:///@localhost:5672
    * Exchange -> celery (direct)
    * Consumer -> Queue:celery Routing:celery
    * Concurrency -> 2
    * Statistics -> OFF
Celery has started.
[INFO/PoolWorker-1] child process calling self.run()
[INFO/PoolWorker-2] child process calling self.run()
[INFO/PoolWorker-1] process shutting down
[INFO/PoolWorker-1] process exiting with exitcode 0
[INFO/PoolWorker-2] process shutting down
[INFO/PoolWorker-2] process exiting with exitcode 0
[Fri Jun 26 08:40:58 2009: FATAL/9106]: celeryd raised exception : content_type
Traceback (most recent call last):
  File "/usr/local/lib/python2.6/dist-packages/celery/bin/celeryd.py", line 267, in run_worker
    worker.start()
  File "/usr/local/lib/python2.6/dist-packages/celery/worker/__init__.py", line 198, in start
    [component.start() for component in self.components]
  File "/usr/local/lib/python2.6/dist-packages/celery/worker/__init__.py", line 56, in start
    it.next()
  File "/usr/local/lib/python2.6/dist-packages/carrot-0.5.0-py2.6.egg/carrot/backends/pyamqplib.py", line 164, in consume
    self.channel.wait()
  File "build/bdist.linux-i686/egg/amqplib/client_0_8/abstract_channel.py", line 82, in wait
    return amqp_method(self, args, content)
  File "build/bdist.linux-i686/egg/amqplib/client_0_8/channel.py", line 1978, in _basic_deliver
    func(msg)
  File "/usr/local/lib/python2.6/dist-packages/carrot-0.5.0-py2.6.egg/carrot/messaging.py", line 269, in _receive_callback
    message = self.backend.message_to_python(raw_message)
  File "/usr/local/lib/python2.6/dist-packages/carrot-0.5.0-py2.6.egg/carrot/backends/pyamqplib.py", line 135, in message_to_python
    return Message(backend=self, amqp_message=raw_message)
  File "/usr/local/lib/python2.6/dist-packages/carrot-0.5.0-py2.6.egg/carrot/backends/pyamqplib.py", line 67, in __init__
    "content_type": amqp_message.content_type,
  File "build/bdist.linux-i686/egg/amqplib/client_0_8/serialization.py", line 454, in __getattr__
    raise AttributeError(name)
AttributeError: content_type

[INFO/MainProcess] process shutting down

[ask]

You should update to carrot >= 0.5.0!

[ask]

Sorry, too fast on the close trigger there. Tasks sent using an older version is actually incompatible with carrot 0.3.20 because of the new version of carrot (0.5.0) which uses the content-type attribute on the AMQP message to define the serialization scheme used. If the old tasks are important, you'd have to contact me for information on how to convert them, if not you can start celeryd with the --discard option to flush out the old messages.