only remove from queue on job.cancel

10 years ago · 5a3bebf85b
parent 786d3c5887
commit 5a3bebf85b
1 changed files with 0 additions and 3 deletions
--- a/rq/job.py
+++ b/rq/job.py
@ -467,9 +467,6 @@ class Job(object):
        """
        from .queue import Queue
        pipeline = self.connection._pipeline()
-        self.delete(pipeline=pipeline)
-        pipeline.delete(self.dependents_key)
-
        if self.origin:
            queue = Queue(name=self.origin, connection=self.connection)
            queue.remove(self, pipeline=pipeline)