mirror of https://github.com/scrapy/scrapy.git
send the response_received signal from the engine, after tying it with the corresponding request
This commit is contained in:
parent
f9aa819b06
commit
668dfcabf3
|
|
@ -82,8 +82,6 @@ class Downloader(object):
|
|||
|
||||
site.active.add(request)
|
||||
def _deactivate(response):
|
||||
send_catch_log(signal=signals.response_received, \
|
||||
response=response, request=request, spider=spider)
|
||||
site.active.remove(request)
|
||||
self._close_if_idle(spider)
|
||||
return response
|
||||
|
|
|
|||
|
|
@ -157,6 +157,8 @@ class ExecutionEngine(object):
|
|||
response.request = request # tie request to response received
|
||||
log.msg(log.formatter.crawled(request, response, spider), \
|
||||
level=log.DEBUG, spider=spider)
|
||||
send_catch_log(signal=signals.response_received, \
|
||||
response=response, request=request, spider=spider)
|
||||
return response
|
||||
elif isinstance(response, Request):
|
||||
return mustbe_deferred(self.schedule, response, spider)
|
||||
|
|
|
|||
Loading…
Reference in New Issue