|
|
@ -142,9 +142,9 @@ class Queue(object):
|
|
|
|
job_id = job_or_id.id if isinstance(job_or_id, self.job_class) else job_or_id
|
|
|
|
job_id = job_or_id.id if isinstance(job_or_id, self.job_class) else job_or_id
|
|
|
|
|
|
|
|
|
|
|
|
if pipeline is not None:
|
|
|
|
if pipeline is not None:
|
|
|
|
pipeline.lrem(self.key, 0, job_id)
|
|
|
|
pipeline.lrem(self.key, 1, job_id)
|
|
|
|
|
|
|
|
|
|
|
|
return self.connection._lrem(self.key, 0, job_id)
|
|
|
|
return self.connection._lrem(self.key, 1, job_id)
|
|
|
|
|
|
|
|
|
|
|
|
def compact(self):
|
|
|
|
def compact(self):
|
|
|
|
"""Removes all "dead" jobs from the queue by cycling through it, while
|
|
|
|
"""Removes all "dead" jobs from the queue by cycling through it, while
|
|
|
|