use internal job_class for check

main
Travis Johnson 10 years ago
parent 3467868f1f
commit 14d1186241

@ -189,7 +189,7 @@ class Queue(object):
# If WatchError is raised in the process, that means something else is # If WatchError is raised in the process, that means something else is
# modifying the dependency. In this case we simply retry # modifying the dependency. In this case we simply retry
if depends_on is not None: 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) depends_on = Job.fetch(id=depends_on, connection=self.connection)
with self.connection.pipeline() as pipe: with self.connection.pipeline() as pipe:
while True: while True:

Loading…
Cancel
Save