python - Received unregistered task using Celery with Django -

-

i have celery setup django project , can't seem task run properly. i'm using django 1.4.3, celery 3.0.1, django-celery 3.0.17 , python 2.7 on ubuntu 13.04.

i have verified rabbitmq-server running:

sudo service rabbitmq-server status status of node rabbit@fenster ... [{pid,1667},  {running_applications,[{rabbit,"rabbitmq","3.0.2"},                         {os_mon,"cpo  cxc 138 46","2.2.9"},                         {mnesia,"mnesia  cxc 138 12","4.7"},                         {sasl,"sasl  cxc 138 11","2.2.1"},                         {stdlib,"erts  cxc 138 10","1.18.1"},                         {kernel,"erts  cxc 138 10","2.15.1"}]},  {os,{unix,linux}},  {erlang_version,"erlang r15b01 (erts-5.9.1) [source] [64-bit] [smp:8:8] [async-threads:30] [kernel-poll:true]\n"},  {memory,[{total,28112760},           {connection_procs,93432},           {queue_procs,42680},           {plugins,0},           {other_proc,9331824},           {mnesia,65288},           {mgmt_db,0},           {msg_index,86656},           {other_ets,764048},           {binary,1343288},           {code,12372068},           {atom,512601},           {other_system,3500875}]},  {vm_memory_high_watermark,0.4},  {vm_memory_limit,6719406080},  {disk_free_limit,1000000000},  {disk_free,122925531136},  {file_descriptors,[{total_limit,924},                     {total_used,7},                     {sockets_limit,829},                     {sockets_used,3}]},  {processes,[{limit,1048576},{used,151}]},  {run_queue,0},  {uptime,275789}] ...done.

i have django project setup in virtualenv. have celery configured in settings.py file as:

installed_apps = [     # django apps      # our apps ...      # third party modules ...     'djcelery', ]  import djcelery djcelery.setup_loader()  celery_imports = ('my.task')

the rabbitmq broker setup - have other celery tasks running properly.

my task:

import celery  class myclass(object):      @celery.task()     def my_task(self, new, old):         # stuff         return      def kick_off_tasks(self):         # stuff         new = 'something'         old = 'something else'         self.my_task.apply_async(args(new, old), kwarg1='new', kwarg2='old)         # more stuff

when run view calls kick_off_tasks receive following in celeryd info log:

./manage.py celeryd --loglevel=info  [tasks]   . my.task   . other.tasks   . more.tasks   . etc.etc.etc  [2013-08-23 14:18:40,772: warning/mainprocess] celery@fenster has started. [2013-08-23 14:20:40,757: error/mainprocess] received unregistered task of type 'my.task'. message has been ignored , discarded.  did remember import module containing task? or maybe using relative imports? please see http://bit.ly/glye1c more information.  full contents of message body was: {'retries': 0, 'task': 'my.task', 'eta': none, 'args': ('something, 'something else'), 'expires': none, 'callbacks': none, 'errbacks': none, 'kwargs': {}, 'id': 'bf4d5ee7-9701-42b6-a887-c6b6470d9810', 'utc': true} (2297b)  traceback (most recent call last):   file "/home/ricomoss/.virtualenvs/proton/local/lib/python2.7/site-packages/celery/worker/consumer.py", line 394, in on_task_received     strategies[name](message, body, message.ack_log_error) keyerror: 'my.task'

any suggestions?

i able working refactoring tasks not class methods. placed them in our tasks.py file , works fine. haven't had time research why case, plan do, until if having same problem you'll have quick fix available.


Comments

Post a Comment

Popular posts from this blog

java - Run a .jar on Heroku -

-
i trying run .jar file on heroku, , can't find instructions anywhere on how this. have read wants me compile uploading heroku. possible, , if is, how this? if helps, trying run minecraft craftbukkit server, , don't have pom.xml file yet. you didn't provide details i'll try give , people reaches question way it. first of all, create heroku account , create heroku application (assumed have done that). second, need generate application jar , upload heroku. so, open terminal , install heroku cli (assuming unix terminal): $ sudo npm install -g heroku-cli you need have npm , nodejs installed, can check link: https://www.digitalocean.com/community/tutorials/how-to-install-node-js-on-ubuntu-16-04 once done that, can use npm update node version acceptable heroku-cli: $ sudo npm install -g n $ sudo n 7.10.0 and run: $ sudo npm install -g heroku-cli in order deploy jars, need install deploy plugin: $ sudo heroku plugins:install heroku-cli-deploy ...
Read more

java - Jtable duplicate Rows -

-
Image
when add new rows in jtable duplicate rows many times this method update jtable public final void tableaucomande(){ ((defaulttablemodel)tabcommande.getmodel()).getdatavector().clear(); session s=hibernateutil.getsessionfactory().opensession(); criteria cr1= s.createcriteria(commande.class); list <commande> lcs=cr1.list() ; criteria cr2= s.createcriteria(lignecommande.class); list <lignecommande> lck=cr2.list() ; if(lcs.size()!=0 && lck.size()!=0) { (commande lc:lcs) { for(lignecommande lig:lck){ ((defaulttablemodel)tabcommande.getmodel()).addrow(new object[]{ lc.getid_cmd(),lc.getnumcmd(),lc.getdate_cmd(),lc.getclient().getnomprenom(), lig.getproduit().getlib_prd(),lig.getquantite(),lig.getproduit().getid_prd() }); } } // tabcommande.setrowselectioninterval(tabcommande.getrowcount()-1,tabcommande.getrowcount()-1); } } this code add add data rows displaye...
Read more

validation - How to pass paramaters like unix into windows batch file -

-
i need pass various parameters .cmd file unix format file.cmd -configuration=value -source=value -flag but, try this: startlocal @echo off cls setlocal set cmdline=%* set configuration= set source= set badargs= set validation= goto main :splitargs echo splitargs(%*) if "%*" neq "" ( /f "tokens=1,2,* delims== " %%i in ("%*") call :assignkeyvalue %%i %%j & call :splitargs %%k ) goto :eof :assignkeyvalue echo assignkeyvalue(%1, %2) if /i %1==-configuration ( set configuration=%2 ) else if /i %1==-source ( set source=%2 ) else ( rem append unrecognised [key,value] badargs echo unknown key %1 set badargs=%badargs%[%1, %2] ) goto :eof :validate echo validating set validation=fail if defined configuration ( echo -configuration ok if defined source ( echo -source ok if not defined badargs ( set validation=success ) ) ) goto :eof :main cl...
Read more