Fix args for unlink_worker subprocess

unlink_worker was not starting and the main process was
dying, due to args being the queue itself, not a tuple
containing the queue.
This commit is contained in:
Ryan Tucker 2011-09-29 09:09:01 -04:00
parent d0ea15beff
commit b5533a843f

View file

@ -332,7 +332,7 @@ if __name__ == '__main__':
send_p.start() send_p.start()
procs.append(send_p) procs.append(send_p)
unlink_p = Process(name="unlink_worker", target=unlink_worker, args=(unlink_queue)) unlink_p = Process(name="unlink_worker", target=unlink_worker, args=(unlink_queue,))
unlink_p.start() unlink_p.start()
procs.append(unlink_p) procs.append(unlink_p)