from flask import Flask
from flask.ext.rq import RQ


app = Flask(__name__)

RQ(app)

from flask.ext.rq import job


@job
def process(i):
    #  Long stuff to process


process.delay(3)

@job('low')
def process(i):
    #  Long stuff to process


process.delay(2)

from flask.ext.rq import get_queue


job = get_queue().enqueue(stuff)  # Creates a job on ``default`` queue
job = get_queue('low').enqueue(stuff)  # Creates a job on ``low`` queue

from flask.ext.rq import get_worker


# Creates a worker that handle jobs in ``default`` queue.
get_worker().work(True)
# Creates a worker that handle jobs in both ``default`` and ``low`` queues.
get_worker('default', 'low').work(True)
# Note: These queues have to share the same connection

app.config['RQ_DEFAULT_HOST'] = 'somewhere.com'
app.config['RQ_DEFAULT_PORT'] = 6479
app.config['RQ_DEFAULT_PASSWORD'] = 'password'
app.config['RQ_DEFAULT_DB'] = 1

app.config['RQ_LOW_URL'] = 'redis://localhost:6379/2'