diff --git a/scrapy/pqueues.py b/scrapy/pqueues.py index e6cd96d43..dcd1ee9f1 100644 --- a/scrapy/pqueues.py +++ b/scrapy/pqueues.py @@ -56,8 +56,11 @@ class ScrapyPriorityQueue(object): return self.downstream_queue_cls(self.crawler, self.key + '/' + str(key)) + def priority(self, request): + return -request.priority + def push(self, request): - priority = -request.priority + priority = self.priority(request) if priority not in self.queues: self.queues[priority] = self.qfactory(priority) q = self.queues[priority]