diff --git a/rq/job.py b/rq/job.py index a7a9fe4..2c0f596 100644 --- a/rq/job.py +++ b/rq/job.py @@ -440,7 +440,7 @@ class Job(object): connection.watch(*self._dependency_ids) jobs = [job - for job in self.fetch_many(self._dependency_ids, connection=self.connection) + for job in self.fetch_many(self._dependency_ids, connection=self.connection, serializer=self.serializer) if job] return jobs