python rq demo

demo.py

from flask import Flask
from rq import Queue
from rq.job import Job
# -----
from redis import Redis
from rq import Worker, Queue, Connection

conn = Redis()
# -----

app = Flask(__name__)
q = Queue(connection=conn)


@app.route('/')
def index():
    return "index"




@app.route('/work')
def work():
    job = q.enqueue(foo, n=3)
    return job.get_id()


@app.route("/results/<job_key>", methods=['GET'])
def get_results(job_key):
    job = Job.fetch(job_key, connection=conn)

    if job.is_finished:
        return str(job.result), 200
    else:
        return "Nay!", 202


if __name__ == '__main__':
    app.run(host='localhost', port='8001')