Don't run lrem directly if we have a pipeline

rq · Dec 8, 2016 · 9e8922a · 9e8922a
1 parent 6721463
commit 9e8922a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rq/queue.py b/rq/queue.py
@@ -150,6 +150,7 @@ def remove(self, job_or_id, pipeline=None):
 
         if pipeline is not None:
             pipeline.lrem(self.key, 1, job_id)
+            return
 
         return self.connection._lrem(self.key, 1, job_id)