lister_base: cache all responses
This commit is contained in:
parent
3c7cfe7d78
commit
7c6ac9df0d
1 changed files with 4 additions and 4 deletions
|
@ -260,6 +260,7 @@ class SWHListerBase(abc.ABC, config.SWHConfig):
|
|||
server response
|
||||
"""
|
||||
retries_left = self.MAX_RETRIES
|
||||
do_cache = self.config['cache_responses']
|
||||
while retries_left > 0:
|
||||
try:
|
||||
r = self.transport_request(identifier)
|
||||
|
@ -271,6 +272,9 @@ class SWHListerBase(abc.ABC, config.SWHConfig):
|
|||
retries_left -= 1
|
||||
continue
|
||||
|
||||
if do_cache:
|
||||
self.save_response(r)
|
||||
|
||||
# detect throttling
|
||||
must_retry, delay = self.transport_quota_check(r)
|
||||
if must_retry:
|
||||
|
@ -285,10 +289,6 @@ class SWHListerBase(abc.ABC, config.SWHConfig):
|
|||
if not retries_left:
|
||||
logging.warn('giving up on %s: max retries exceeded' % identifier)
|
||||
|
||||
do_cache = self.config['cache_responses']
|
||||
if do_cache:
|
||||
self.save_response(r)
|
||||
|
||||
return r
|
||||
|
||||
def db_query_equal(self, key, value):
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue