import tornado.ioloop
import tornado.web
from tornado.gen import coroutine

from tasks import test
import torncelery


class MainHandler(tornado.web.RequestHandler):
    @coroutine
    def get(self):
        result = yield torncelery.async(test, "hello world")
        self.write("%s" % result )

application = tornado.web.Application([
    (r"/", MainHandler),
])

if __name__ == "__main__":
    application.listen(8888)
    tornado.ioloop.IOLoop.instance().start()

from celery import Celery
import time 

celery = Celery('tasks', backend='redis://localhost', broker='amqp://')


@celery.task
def test(strs):
    return strs

celery -A tasks worker --loglevel=info -n new