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
cela mérite d'être la bonne réponse maintenant. – psychok7
savez-vous s'il existe un moyen de surveiller le statut des travailleurs avec ces paquets? – psychok7