2016-09-20 1 views
0

J'utilise Django 1.10 + celery==4.0.0rc3 + django-celery with commit @79d9689b62db3d54ebd0346e00287f91785f6355.Celery - Aucun module nommé 'celery.datastructures'

Mes paramètres sont les suivants:

CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend' 
CELERY_ACCEPT_CONTENT = ['json'] 
CELERY_TASK_SERIALIZER = 'json' 
CELERY_RESULT_SERIALIZER = 'json' 
CELERY_TIMEZONE = TIME_ZONE 
# http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html#visibility-timeout 
BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 259200} # 3 days 

mon tasks.py j'ai

@task(queue='assign_rnal_id') 
def assign_rnal_id_to_mongo(rnal_id, mongo_id): 
    print ("something") 

    return False 

Dans mon modèle django je suis Redéfinition de la méthode de sauvegarde d'envoyer une tâche à céleri:

def save(self, *args, **kwargs): 
    super(Suggested, self).save(*args, **kwargs) 

     assign_rnal_id_to_mongo.delay(rnal_id=self.id, mongo_id=self.raw_data['_id']) 

Lorsque je sauvegarde mon objet modèle, j'obtiens un No module named 'celery.datastructures'

Des idées? J'ai un code similaire qui fonctionne pour les anciennes versions de django et de céleri, est-ce que quelque chose a changé?

Merci

Répondre

1

En utilisant django 1.10 et Céleri 4.0.x je devais

Cela a résolu le problème pour moi sans avoir besoin de rétrograder mon céleri.

+0

cela mérite d'être la bonne réponse maintenant. – psychok7

+0

savez-vous s'il existe un moyen de surveiller le statut des travailleurs avec ces paquets? – psychok7

0

j'ai pu trouver la réponse ici https://github.com/celery/celery/issues/3303#issuecomment-246780116

Fondamentalement Django-celery does not support 4.0 yet donc je rétrogradé à celery==3.1.23 et il fonctionne maintenant

+2

Oui! Django-céleri a été remplacé par deux nouvelles bibliothèques pour 4.0: django-céleri-résultats et django-céleri-beat. Nous ferons probablement du django-céleri avant la sortie pour que ça marche, mais il y a eu beaucoup de confusion quand le django-céleri est nécessaire, et maintenant la réponse n'est jamais. – asksol