mirror of https://github.com/scrapy/scrapy.git
Converted map() to list comprehension or generator for Python 3 compatibility
This commit is contained in:
parent
911c8082b0
commit
6b35166de6
|
|
@ -81,7 +81,7 @@ class CookiesMiddleware(object):
|
||||||
else:
|
else:
|
||||||
cookie_list = request.cookies
|
cookie_list = request.cookies
|
||||||
|
|
||||||
cookies = map(self._format_cookie, cookie_list)
|
cookies = [self._format_cookie(x) for x in cookie_list]
|
||||||
headers = {'Set-Cookie': cookies}
|
headers = {'Set-Cookie': cookies}
|
||||||
response = Response(request.url, headers=headers)
|
response = Response(request.url, headers=headers)
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -15,7 +15,7 @@ class DummyPolicy(object):
|
||||||
|
|
||||||
def __init__(self, settings):
|
def __init__(self, settings):
|
||||||
self.ignore_schemes = settings.getlist('HTTPCACHE_IGNORE_SCHEMES')
|
self.ignore_schemes = settings.getlist('HTTPCACHE_IGNORE_SCHEMES')
|
||||||
self.ignore_http_codes = map(int, settings.getlist('HTTPCACHE_IGNORE_HTTP_CODES'))
|
self.ignore_http_codes = [int(x) for x in settings.getlist('HTTPCACHE_IGNORE_HTTP_CODES')]
|
||||||
|
|
||||||
def should_cache_request(self, request):
|
def should_cache_request(self, request):
|
||||||
return urlparse_cached(request).scheme not in self.ignore_schemes
|
return urlparse_cached(request).scheme not in self.ignore_schemes
|
||||||
|
|
|
||||||
|
|
@ -34,7 +34,7 @@ class TelnetConsole(protocol.ServerFactory):
|
||||||
raise NotConfigured
|
raise NotConfigured
|
||||||
self.crawler = crawler
|
self.crawler = crawler
|
||||||
self.noisy = False
|
self.noisy = False
|
||||||
self.portrange = map(int, crawler.settings.getlist('TELNETCONSOLE_PORT'))
|
self.portrange = [int(x) for x in crawler.settings.getlist('TELNETCONSOLE_PORT')]
|
||||||
self.host = crawler.settings['TELNETCONSOLE_HOST']
|
self.host = crawler.settings['TELNETCONSOLE_HOST']
|
||||||
self.crawler.signals.connect(self.start_listening, signals.engine_started)
|
self.crawler.signals.connect(self.start_listening, signals.engine_started)
|
||||||
self.crawler.signals.connect(self.stop_listening, signals.engine_stopped)
|
self.crawler.signals.connect(self.stop_listening, signals.engine_stopped)
|
||||||
|
|
|
||||||
|
|
@ -91,7 +91,7 @@ class ContractsManagerTest(unittest.TestCase):
|
||||||
# extract contracts correctly
|
# extract contracts correctly
|
||||||
contracts = self.conman.extract_contracts(spider.returns_request)
|
contracts = self.conman.extract_contracts(spider.returns_request)
|
||||||
self.assertEqual(len(contracts), 2)
|
self.assertEqual(len(contracts), 2)
|
||||||
self.assertEqual(frozenset(map(type, contracts)),
|
self.assertEqual(frozenset(type(x) for x in contracts),
|
||||||
frozenset([UrlContract, ReturnsContract]))
|
frozenset([UrlContract, ReturnsContract]))
|
||||||
|
|
||||||
# returns request for valid method
|
# returns request for valid method
|
||||||
|
|
@ -109,13 +109,13 @@ class ContractsManagerTest(unittest.TestCase):
|
||||||
# returns_item
|
# returns_item
|
||||||
request = self.conman.from_method(spider.returns_item, self.results)
|
request = self.conman.from_method(spider.returns_item, self.results)
|
||||||
output = request.callback(response)
|
output = request.callback(response)
|
||||||
self.assertEqual(map(type, output), [TestItem])
|
self.assertEqual([type(x) for x in output], [TestItem])
|
||||||
self.should_succeed()
|
self.should_succeed()
|
||||||
|
|
||||||
# returns_request
|
# returns_request
|
||||||
request = self.conman.from_method(spider.returns_request, self.results)
|
request = self.conman.from_method(spider.returns_request, self.results)
|
||||||
output = request.callback(response)
|
output = request.callback(response)
|
||||||
self.assertEqual(map(type, output), [Request])
|
self.assertEqual([type(x) for x in output], [Request])
|
||||||
self.should_succeed()
|
self.should_succeed()
|
||||||
|
|
||||||
# returns_fail
|
# returns_fail
|
||||||
|
|
@ -130,7 +130,7 @@ class ContractsManagerTest(unittest.TestCase):
|
||||||
# scrapes_item_ok
|
# scrapes_item_ok
|
||||||
request = self.conman.from_method(spider.scrapes_item_ok, self.results)
|
request = self.conman.from_method(spider.scrapes_item_ok, self.results)
|
||||||
output = request.callback(response)
|
output = request.callback(response)
|
||||||
self.assertEqual(map(type, output), [TestItem])
|
self.assertEqual([type(x) for x in output], [TestItem])
|
||||||
self.should_succeed()
|
self.should_succeed()
|
||||||
|
|
||||||
# scrapes_item_fail
|
# scrapes_item_fail
|
||||||
|
|
|
||||||
|
|
@ -8,7 +8,7 @@ class ScrapyUtilsTest(unittest.TestCase):
|
||||||
raise unittest.SkipTest("OpenSSL is not available")
|
raise unittest.SkipTest("OpenSSL is not available")
|
||||||
|
|
||||||
if hasattr(module, '__version__'):
|
if hasattr(module, '__version__'):
|
||||||
installed_version = map(int, module.__version__.split('.')[:2])
|
installed_version = [int(x) for x in module.__version__.split('.')[:2]]
|
||||||
assert installed_version >= [0, 6], "OpenSSL >= 0.6 required"
|
assert installed_version >= [0, 6], "OpenSSL >= 0.6 required"
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
|
|
|
||||||
|
|
@ -63,12 +63,14 @@ class FilesPipelineTestCase(unittest.TestCase):
|
||||||
mock.patch.object(FilesPipeline, 'get_media_requests',
|
mock.patch.object(FilesPipeline, 'get_media_requests',
|
||||||
return_value=[_prepare_request_object(item_url)])
|
return_value=[_prepare_request_object(item_url)])
|
||||||
]
|
]
|
||||||
map(lambda p: p.start(), patchers)
|
for p in patchers:
|
||||||
|
p.start()
|
||||||
|
|
||||||
result = yield self.pipeline.process_item(item, None)
|
result = yield self.pipeline.process_item(item, None)
|
||||||
self.assertEqual(result['files'][0]['checksum'], 'abc')
|
self.assertEqual(result['files'][0]['checksum'], 'abc')
|
||||||
|
|
||||||
map(lambda p: p.stop(), patchers)
|
for p in patchers:
|
||||||
|
p.stop()
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def test_file_expired(self):
|
def test_file_expired(self):
|
||||||
|
|
@ -82,12 +84,14 @@ class FilesPipelineTestCase(unittest.TestCase):
|
||||||
return_value=[_prepare_request_object(item_url)]),
|
return_value=[_prepare_request_object(item_url)]),
|
||||||
mock.patch.object(FilesPipeline, 'inc_stats', return_value=True)
|
mock.patch.object(FilesPipeline, 'inc_stats', return_value=True)
|
||||||
]
|
]
|
||||||
map(lambda p: p.start(), patchers)
|
for p in patchers:
|
||||||
|
p.start()
|
||||||
|
|
||||||
result = yield self.pipeline.process_item(item, None)
|
result = yield self.pipeline.process_item(item, None)
|
||||||
self.assertNotEqual(result['files'][0]['checksum'], 'abc')
|
self.assertNotEqual(result['files'][0]['checksum'], 'abc')
|
||||||
|
|
||||||
map(lambda p: p.stop(), patchers)
|
for p in patchers:
|
||||||
|
p.stop()
|
||||||
|
|
||||||
class FilesPipelineTestCaseFields(unittest.TestCase):
|
class FilesPipelineTestCaseFields(unittest.TestCase):
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -69,7 +69,7 @@ class WebService(server.Site):
|
||||||
raise NotConfigured
|
raise NotConfigured
|
||||||
self.crawler = crawler
|
self.crawler = crawler
|
||||||
logfile = crawler.settings['WEBSERVICE_LOGFILE']
|
logfile = crawler.settings['WEBSERVICE_LOGFILE']
|
||||||
self.portrange = map(int, crawler.settings.getlist('WEBSERVICE_PORT'))
|
self.portrange = [int(x) for x in crawler.settings.getlist('WEBSERVICE_PORT')]
|
||||||
self.host = crawler.settings['WEBSERVICE_HOST']
|
self.host = crawler.settings['WEBSERVICE_HOST']
|
||||||
root = RootResource(crawler)
|
root = RootResource(crawler)
|
||||||
reslist = build_component_list(crawler.settings['WEBSERVICE_RESOURCES_BASE'], \
|
reslist = build_component_list(crawler.settings['WEBSERVICE_RESOURCES_BASE'], \
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue