#!/usr/bin/env python3
import os
from multiprocessing import Pool

import redis
from rq import Worker, Queue, Connection

listen = ['default']

redis_url = 'redis://localhost:6379'

conn = redis.from_url(redis_url)
q = Queue('default', connection=conn)

def do_work(elem):
    with Connection(conn) as c:
        print("working")
        worker = Worker([q])
        worker.work()
        print("finished")

if __name__ == '__main__':
    p = Pool(2)
    p.map(do_work, [1,2])