2016-04-21 1 views
0

J'ai 3 employés et je suis en train de créer plusieurs tâches de céleri comme ceci:comment boucle sur et créer plusieurs tâches de céleri django

for e in employees: 
    res1 = escalate.apply_async((e.id), countdown=3) 
    print res1.id 

Cela devrait créer 3 tâches, mais il ne crée que 1.

Chaque imprime id sur: dc553662-283e-46e5-b811-7c1f5ed08d2d be7043bc-02a1-4641-b8e6-c230bf1d7325 5b88e6cc-8514-4e80-8f4f-eb8b05f3625b

est-il limité dans le céleri qui doens't permettre moi de créer plusieurs tâches de cette façon? Si non, comment puis-je créer plusieurs tâches dans une boucle?

+0

Comment savez-vous qu'il ne crée qu'une seule tâche de céleri? Pourriez-vous imprimer 'res1.id' après chaque appel? – AKS

+0

J'imprime toutes les tâches et chacune a un identifiant. Qu'est-ce que ça veut dire? Comment puis-je faire les tâches qui ont un ID, mais ne tirent pas? – Atma

Répondre

0

Vous pouvez transmettre ces identifiants d'employés sous la forme d'une liste à la tâche, passer en revue dans la tâche "escalade" et effectuer la fonctionnalité que vous souhaitez. Voilà comment j'aurais été avec ça.