Celery Queue ne semble pas enregistrer mes tâches

Question

J'utilise Django et Céleri pour communiquer avec RabbitMQ. J'ai enregistré toutes les tâches et les ai placées dans le tuple CELERY_IMPORTS dans mon fichier de paramètres. Lorsque j'exécute une tâche, j'obtiens le message d'erreur "non enregistré".

# tail -f /var/log/celeryd.log 
    . logfile -> /var/log/celeryd.log@INFO 
    . events -> OFF 
    . beat -> OFF 
    . tasks -> 
    . apps.contact.tasks.emailContact 
    . apps.declaration.tasks.MailChimpSignup 
    . apps.questions.tasks.emailQuestionTask 
    . queued_storage.tasks.SaveToRemoteTask 
[2010-10-19 17:53:44,958: INFO/PoolWorker-1] child process calling self.run() 
[2010-10-19 17:53:44,971: WARNING/MainProcess] celery@nolabels.org has started. 


[2010-10-19 17:54:03,962: ERROR/MainProcess] Unknown task ignored: "Task of kind 'apps.declaration.tasks.MailChimpSignup' is not registered, please make sure it's imported.": {'retries': 0, 'task': 'apps.declaration.tasks.MailChimpSignup', 'args': [], 'eta': None, 'kwargs': {'email': u'abc123@asdfd.com'}, 'id': '919c6030-70b1-43e6-87f5-907fa0f52c08'} 

Heres ce que ma définition de tâche ressemble à:

class MailChimpSignup(Task): 
    def run(self, email, **kwargs): 
     """ 
     This will register the declaration signer on mail chimp. 
     """ 
     logger = self.get_logger(**kwargs) 
     logger.info("Processed mailchimp signup for %s" % email) 
     chimp = chimpy.Connection(settings.MAILCHIMP_API_KEY) 

     try: 
      chimp.list_member_info(settings.MAILCHIMP_LIST_ID, email) 
     except ChimpyException: 
      try: 
       x = chimp.list_subscribe(
         settings.MAILCHIMP_LIST_ID, 
         email, 
         { 
         # 'FNAME': self.first_name, 
         # 'LNAME': self.last_name, 
         }, 
         email_type='HTML', 
         double_optin = False, 
       ) 
      except ChimpyException: 
       return False 
     return True 
tasks.register(MailChimpSignup) 

Answer 1

étrange. Cela semble avoir les bons noms.

Pourriez-vous essayer d'attribuer manuellement un nom à la tâche?

@task(name="MailChimpSignup") 
def ...