test_celery/tasks.py

   1 from __future__ import absolute_import
   2 from test_celery.celery import app
   3 import time
   4
   5
   6 @app.task
   7 def longtime_add(x, y):
   8     print ('long time task begins')
   9     # sleep 5 seconds
  10     time.sleep(5)
  11     print ('long time task finished')
  12     return x + y