Advertisement
Guest User

Untitled

a guest
Aug 30th, 2014
275
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.47 KB | None | 0 0
  1. @shared_task(ignore_result=True)
  2. def update():
  3. group([app1.tasks.update.s(), app2.tasks.update.s()])()
  4.  
  5. Received task: main.tasks.update[1a26fb7c-...]
  6. Received task: app2.tasks.update[9c183d56-...]
  7. Task main.tasks.update[1a26fb7c-...] succeeded in 0.072...s: None
  8. Task app2.tasks.update[9c183d56-...] succeeded in 2.000...s: None
  9.  
  10. proj/app1/tasks
  11. proj/app2/tasks
  12. proj/main/tasks
  13.  
  14. # main/tasks.py
  15. from celery import shared_task, group
  16. import app1.tasks
  17. import app2.tasks
  18. @shared_task(ignore_result=True)
  19. def update():
  20. group([app1.tasks.update.s(), app2.tasks.update.s()])()
  21.  
  22. # app1/tasks.py
  23. @shared_task(ignore_result=True)
  24. def update():
  25. sleep(5)
  26.  
  27. # app2/tasks.py
  28. @shared_task(ignore_result=True)
  29. def update():
  30. sleep(2)
  31.  
  32. celery -A main worker -l info
  33.  
  34. Received task: main.tasks.update[1a26fb7c-...]
  35. Received task: app2.tasks.update[9c183d56-...]
  36. Task main.tasks.update[1a26fb7c-...] succeeded in 0.072...s: None
  37. Task app2.tasks.update[9c183d56-...] succeeded in 2.000...s: None
  38.  
  39. # main/tasks.py
  40. @shared_task(ignore_result=True)
  41. def update():
  42. group([app2.tasks.update.s(), app1.tasks.update.s()])()
  43.  
  44. Received task: main.tasks.update[231b7bd1-...]
  45. Received task: app1.tasks.update[3491961a-...]
  46. Task main.tasks.update[231b7bd1-...] succeeded in 0.072...s: None
  47. Task app1.tasks.update[3491961a-...] succeeded in 5.000...s: None
  48.  
  49. # main/tasks.py
  50. @shared_task(ignore_result=True)
  51. def update():
  52. app2.tasks.update.s().delay()
  53. app1.tasks.update.s().delay()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement