rq_worker.py

import sys
from rq import Queue, Connection, Worker

if __name__ == '__main__':
    # Provide queue names to listen to as arguments to this script,
    # similar to rqworker
    with Connection():
        qs = map(Queue, sys.argv[1:]) or [Queue()]
        w = Worker(qs)
        w.work()