Re: problems with django-celery

Hi Mateusz,

Were you able to solve this? I am also facing the same issue.

Thanks,

Sachin

On Tuesday, March 26, 2013 4:35:41 PM UTC+5:30, Mateusz Iwański wrote:

Hi,

I have a problem with django-celery. When i want to delay function I get an error from celery worker, it happens every second time when i want to use it. 

Error from celery worker:

Can't decode message body: ImportError('No module named manager.apps.ffmpeg.tasks',) (type:u'application/x-python-serialize' encoding:u'binary' raw:"'\\x80\\x02}q\\x01(U\\x07expiresq\\x02NU\\x03utcq\\x03\\x88U\\x04argsq\\x04cmanager.apps.ffmpeg.tasks\\nFfmpegTasks\\nq\\x05)\\x81q\\x06}q\\x07(U\\tfile_pathq\\x08X*\\x00\\x00\\x00/media/temp/video/2462009/8132009624142319U\\x02IDq\\tM\\x1eDU\\x0cvideo_objectq\\ncdjango.db.models.base\\nmodel_unpickle\\nq\\x0bcmanager.apps.manager.models\\nVideoContent\\nq\\x0c]cdjango.db.models.base\\nsimple_class_factory\\nq\\r\\x87Rq\\x0e}q\\x0f(U\\x08date_addq\\x10cdatetime\\ndatetime\\nq\\x11U\\n\\x07\\xd9\\x06\\x18\\x0e\\x17\\x00\\x00\\x00\\x00cpytz\\n_UTC\\nq\\x12)Rq\\x13\\x86Rq\\x14U\\x04busyq\\x15\\x89U\\x0bdescriptionq\\x16XF\\x00\\x00\\x00Spotkanie z Wand? P\\xc3\\xb3?tawsk?, przyjaci\\xc3\\xb3?k? Jana Paw?a II cz??c druga.U\\x0f_category_cacheq\\x17h\\x0bcmanager.apps.manager.models\\nVideoCategory\\nq\\x18]h\\r\\x87Rq\\x19}q\\x1a(U\\x06_stateq\\x1bcdjango.db.models.base\\nModelState\\nq\\x1c)\\x81q\\x1d}q\\x1e(U\\x06addingq\\x1f\\x89U\\x02dbq... (1317b)"')

I installed librabbitmq and worker after that give me an error:

Can't decode message body: ImportError('No module named manager.apps.ffmpeg.tasks',) (type:'application/x-python-serialize' encoding:'binary' raw:'<read-only buffer ptr 0xa89c117, size 1277 at 0xa7af9e0> (1277b)'') 

First time when i delay function everything is OK the second time I have an error the third time work properly and so on.

RabbitMQ 3.0.4

Django 1.4.0

Linux version 3.2.0-39-generic (buildd@aatxe) (gcc version 4.6.3 (Ubuntu/Linaro 4.6.3-1ubuntu5) ) #62-Ubuntu SMP Wed Feb 27 22:05:17 UTC 2013

celery report :

software -> celery:3.0.17 (Chiastic Slide) kombu:2.5.8 py:2.7.3

            billiard:2.7.3.23 librabbitmq:1.0.1

platform -> system:Linux arch:32bit, ELF imp:CPython

loader   -> celery.loaders.default.Loader

settings -> transport:librabbitmq results:disabled

__class__: <type 'dict'>

__cmp__: <method-wrapper '__cmp__' of dict object at 0xa6fa934>

__contains__: <built-in method __contains__ of dict object at 0xa6fa934>

__delattr__: <method-wrapper '__delattr__' of dict object at 0xa6fa934>

__delitem__: <method-wrapper '__delitem__' of dict object at 0xa6fa934>

__doc__: "dict() -> new empty dictionary\ndict(mapping) -> new dictionary initialized from a mapping object's\n    (key, value) pairs\ndict(iterable) -> new dictionary initialized as if via:\n    d = {}\n    for k, v in iterable:\n        d[k] = v\ndict(**kwargs) -> new dictionary initialized with the name=value pairs\n    in the keyword argument list.  For example:  dict(one=1, two=2)"

__eq__: <method-wrapper '__eq__' of dict object at 0xa6fa934>

__format__: <built-in method __format__ of dict object at 0xa6fa934>

__ge__: <method-wrapper '__ge__' of dict object at 0xa6fa934>

__getattribute__: <method-wrapper '__getattribute__' of dict object at 0xa6fa934>

__getitem__: <built-in method __getitem__ of dict object at 0xa6fa934>

__gt__: <method-wrapper '__gt__' of dict object at 0xa6fa934>

__hash__: None

__init__: <method-wrapper '__init__' of dict object at 0xa6fa934>

__iter__: <method-wrapper '__iter__' of dict object at 0xa6fa934>

__le__: <method-wrapper '__le__' of dict object at 0xa6fa934>

__len__: <method-wrapper '__len__' of dict object at 0xa6fa934>

__lt__: <method-wrapper '__lt__' of dict object at 0xa6fa934>

__ne__: <method-wrapper '__ne__' of dict object at 0xa6fa934>

__new__: <built-in method __new__ of type object at 0x82bb380>

__reduce__: <built-in method __reduce__ of dict object at 0xa6fa934>

__reduce_ex__: <built-in method __reduce_ex__ of dict object at 0xa6fa934>

__repr__: <method-wrapper '__repr__' of dict object at 0xa6fa934>

__setattr__: <method-wrapper '__setattr__' of dict object at 0xa6fa934>

__setitem__: <method-wrapper '__setitem__' of dict object at 0xa6fa934>

__sizeof__: <built-in method __sizeof__ of dict object at 0xa6fa934>

__str__: <method-wrapper '__str__' of dict object at 0xa6fa934>

__subclasshook__: <built-in method __subclasshook__ of type object at 0x82bb380>

clear: <built-in method clear of dict object at 0xa6fa934>

copy: <built-in method copy of dict object at 0xa6fa934>

fromkeys: <built-in method fromkeys of type object at 0x82bb380>

get: <built-in method get of dict object at 0xa6fa934>

has_key: <built-in method has_key of dict object at 0xa6fa934>

items: <built-in method items of dict object at 0xa6fa934>

iteritems: <built-in method iteritems of dict object at 0xa6fa934>

iterkeys: <built-in method iterkeys of dict object at 0xa6fa934>

itervalues: <built-in method itervalues of dict object at 0xa6fa934>

keys: <built-in method keys of dict object at 0xa6fa934>

pop: <built-in method pop of dict object at 0xa6fa934>

popitem: <built-in method popitem of dict object at 0xa6fa934>

setdefault: <built-in method setdefault of dict object at 0xa6fa934>

update: <built-in method update of dict object at 0xa6fa934>

values: <built-in method values of dict object at 0xa6fa934>

viewitems: <built-in method viewitems of dict object at 0xa6fa934>

viewkeys: <built-in method viewkeys of dict object at 0xa6fa934>

viewvalues: <built-in method viewvalues of dict object at 0xa6fa934>

--
You received this message because you are subscribed to the Google Groups "Django users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to django-users+unsubscribe@googlegroups.com.
To post to this group, send email to django-users@googlegroups.com.
Visit this group at http://groups.google.com/group/django-users.
For more options, visit https://groups.google.com/groups/opt_out.