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

Merge pull request #4 from sprockets/fix-httperror

Browse source 
HTTPError.message is not a thing
This commit is contained in:
dave-shawley 2016-03-24 16:55:13 -04:00
commit 9c8ce88169
2 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
sprockets/clients/dynamodb/__init__.py
View file

@ -4,7 +4,7 @@ except ImportError as error:
def DynamoDB(*args, **kwargs): def DynamoDB(*args, **kwargs):
raise error raise error
version_info = (0, 2, 0) version_info = (0, 2, 1)
__version__ = '.'.join(str(v) for v in version_info) __version__ = '.'.join(str(v) for v in version_info)
# Response constants # Response constants

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

@ -104,8 +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 = str(http_err.code)
if http_err.response and \
hasattr(http_err.response, 'body'):
response_reason = http_err.response.body
future.set_exception( future.set_exception(
exceptions.RequestException(http_err.message)) exceptions.RequestException(response_reason))
except Exception as exception: except Exception as exception:
future.set_exception(exception) future.set_exception(exception)
else: else:
@ -126,7 +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:
future.set_exception(exceptions.RequestException(err.message)) reason = str(err.code)
if err.response and hasattr(err.response, 'body'):
reason = err.response.body
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