rq icon indicating copy to clipboard operation
rq copied to clipboard

how to specify a pipeline to a worker

Open Cookie-YY opened this issue 3 years ago • 1 comments

when I want to start a worker in python. I use it in this way.

with Connection(redis_instance):
    worker = Worker(map(Queue, RQ_QUEUE_NAMES))
    worker.work()

when call work(), it uses a pipeline in redis, how can I specify the pipeline?

background info: the redis cluster can't support some commands.

Cookie-YY avatar May 23 '22 10:05 Cookie-YY

worker.work() itself does not accept pipeline argument. You'll need to be more specific as to which Redis commands that RQ uses that's not supported by Redis cluster.

selwin avatar Jul 24 '22 00:07 selwin