From 14d118624156bfc625f07153a24818a073dcdae7 Mon Sep 17 00:00:00 2001 From: Travis Johnson Date: Mon, 17 Nov 2014 15:04:20 -0500 Subject: [PATCH] use internal job_class for check --- rq/queue.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/queue.py b/rq/queue.py index ff40e032..ff5f8607 100644 --- a/rq/queue.py +++ b/rq/queue.py @@ -189,7 +189,7 @@ class Queue(object): # If WatchError is raised in the process, that means something else is # modifying the dependency. In this case we simply retry if depends_on is not None: - if not isinstance(depends_on, Job): + if not isinstance(depends_on, self.job_class): depends_on = Job.fetch(id=depends_on, connection=self.connection) with self.connection.pipeline() as pipe: while True: