AutoWorker

Spawn RQ Workers automatically. This project work based on the original autoworker.

from redis import Redis
from rq import Queue
from autoworker import AutoWorkerQueue

q = AutoWorkerQueue(name="queue_test", connection=Redis())

for x in range(10):
    q.enqueue(print_foo)

Note: From v0.4.0 failed jobs doesn't go to the failed queue. If you want to enqueue to failed queue you should call AutoWorker as following

.. code-block:: python

aw = AutoWorker(queue='high', max_procs=6, skip_failed=False)