diff --git a/rq/queue.py b/rq/queue.py index e9772f164..417141aba 100644 --- 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)