Fix pipeline call.

11 years ago · fdf4abcf69
parent 76e2470c67
commit fdf4abcf69
1 changed files with 1 additions and 1 deletions
--- a/rq/job.py
+++ b/rq/job.py
@ -433,7 +433,7 @@ class Job(object):
        cancellation.  Technically, this call is (currently) the same as just
        deleting the job hash.
        """
-        pipeline = self.connection.pipeline()
+        pipeline = self.connection._pipeline()
        self.delete(pipeline=pipeline)
        pipeline.delete(self.dependents_key)
        pipeline.execute()