github/sprockets.clients.dynamodb
1
0
Fork 0
mirror of https://github.com/sprockets/sprockets.clients.dynamodb.git synced 2024-11-23 19:29:51 +00:00
Code Issues Projects Releases Packages Wiki Activity

Actually raise an exception

Browse source
This commit is contained in:
Gavin M. Roy 2016-03-24 16:42:29 -04:00
parent 69888b6b71
commit 5219e025e9
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
sprockets/clients/dynamodb/connector.py
View file

@ -104,11 +104,12 @@ class DynamoDB(object):
if http_err.code == 599: if http_err.code == 599:
future.set_exception(exceptions.TimeoutException()) future.set_exception(exceptions.TimeoutException())
else: else:
response_reason = http_err.code response_reason = str(http_err.code)
if http_err.response and \ if http_err.response and \
hasattr(http_err.response, 'body'): hasattr(http_err.response, 'body'):
response_reason = http_err.response.body response_reason = http_err.response.body
future.set_exception(response_reason) future.set_exception(
exceptions.RequestException(response_reason))
except Exception as exception: except Exception as exception:
future.set_exception(exception) future.set_exception(exception)
else: else:
@ -129,10 +130,11 @@ class DynamoDB(object):
if err.code == 599: if err.code == 599:
future.set_exception(exceptions.TimeoutException()) future.set_exception(exceptions.TimeoutException())
else: else:
reason = err.code reason = str(err.code)
if err.response and hasattr(err.response, 'body'): if err.response and hasattr(err.response, 'body'):
reason = err.response.body reason = err.response.body
future.set_exception(reason) future.set_exception(exceptions.RequestException(reason))
else: else:
ioloop.IOLoop.current().add_future(aws_response, handle_response) ioloop.IOLoop.current().add_future(aws_response, handle_response)
return future return future