RomanNum3ral
/
scrapy
mirror of https://github.com/scrapy/scrapy.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

one more argument for common interface

This commit is contained in:
Vostretsov Nikita 2019-07-15 04:05:46 +05:00
parent ee4539b68d
commit d79f49c4b3
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
scrapy/pqueues.py
View File

@ -54,6 +54,7 @@ class ScrapyPriorityQueue(object):
def qfactory(self, key, startprios=()):
return self.downstream_queue_cls(self.crawler,
None,
self.key + '/' + str(key),
startprios)

4
scrapy/squeues.py
View File

@ -47,7 +47,7 @@ def _scrapy_serialization_queue(queue_class):
class ScrapyRequestQueue(queue_class):
def __init__(self, crawler, key, startprios):
def __init__(self, crawler, downstream_queue_cls, key, startprios):
self.spider = crawler.spider
super(ScrapyRequestQueue, self).__init__(key)
@ -70,7 +70,7 @@ def _scrapy_serialization_queue(queue_class):
def _scrapy_in_memory_queue(queue_class):
class ScrapyRequestQueue(queue_class):
def __init__(self, crawler, key, startprios):
def __init__(self, crawler, downstream_queue_cls, key, startprios):
super(ScrapyRequestQueue, self).__init__()
return ScrapyRequestQueue