Use correct error for new aiohttp 2.0
@@ -266,7 +266,7 @@ class AWSSNSSQSTransport(Invoker):
error_message = str(e)
logging.getLogger('transport.aws_sns_sqs').warn('Unable to connect [sqs] to AWS ({})'.format(error_message))
raise AWSSNSSQSConnectionException(str(e), log_level=context.get('log_level')) from e
- except aiohttp.errors.ClientOSError as e:
+ except aiohttp.client_exceptions.ClientOSError as e:
error_message = str(e)
logging.getLogger('transport.aws_sns_sqs').warn('Unable to connect [sqs] to AWS ({})'.format(error_message))
raise AWSSNSSQSConnectionException(str(e), log_level=context.get('log_level')) from e
