1
0
Fork 0
mirror of synced 2024-06-26 18:10:26 +12:00

Add more informative errors when downloading Resource

This commit is contained in:
Serene-Arc 2021-04-05 15:11:17 +10:00 committed by Ali Parlakci
parent c2c3d03205
commit b5b163084f

View file

@ -33,27 +33,30 @@ class Resource:
if response.status_code == 200:
return response.content
elif response.status_code in (301, 401, 403, 404):
logger.error(f'Unrecoverable error requesting resource: HTTP Code {response.status_code}')
return None
raise BulkDownloaderException(f'Unrecoverable error requesting resource: HTTP Code {response.status_code}')
else:
raise requests.exceptions.ConnectionError
except requests.exceptions.ConnectionError:
logger.log(9, f'Error occured downloading resource, waiting {wait_time} seconds')
raise requests.exceptions.ConnectionError(f'Response code {response.status_code}')
except requests.exceptions.ConnectionError as e:
logger.log(9, f'Error occured downloading resource, waiting {wait_time} seconds: {e}')
time.sleep(wait_time)
if wait_time < 300:
return Resource.retry_download(url, wait_time + 60)
else:
logger.error(f'Max wait time exceeded for resource at url {url}')
return None
raise
def download(self):
if not self.content:
content = self.retry_download(self.url, 0)
try:
content = self.retry_download(self.url, 0)
except requests.exceptions.ConnectionError as e:
raise BulkDownloaderException(f'Could not download resource: {e}')
except BulkDownloaderException:
raise
if content:
self.content = content
self.create_hash()
else:
raise BulkDownloaderException('Could not download resource')
if not self.hash and self.content:
self.create_hash()
def create_hash(self):
self.hash = hashlib.md5(self.content)