diff --git a/rq/job.py b/rq/job.py index 8409eee8..87bd83e1 100644 --- 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()