return FAILURE
except exception.ClientConfigurationError:
raise
- except exception.KeystoneError, e:
+ except exception.KeystoneError as e:
LOG.error("Keystone did not finish the authentication and "
"returned the following message:\n\n%s" % e.message)
return FAILURE
- except Exception, e:
+ except Exception as e:
options = arguments[0]
if options.debug:
raise
LOG.info('Invalid user token - rejecting request')
return self._reject_request(env, start_response)
- except ServiceError, e:
+ except ServiceError as e:
LOG.critical('Unable to obtain admin token: %s' % e)
resp = webob.exc.HTTPServiceUnavailable()
return resp(env, start_response)
conn.request(method, path, **kwargs)
response = conn.getresponse()
body = response.read()
- except Exception, e:
+ except Exception as e:
LOG.error('HTTP connection exception: %s' % e)
raise ServiceError('Unable to communicate with keystone')
finally:
else:
raise Exception("Unknown error occurred! %s" % res.read())
- except (socket.error, IOError), e:
+ except (socket.error, IOError) as e:
raise exception.ClientConnectionError(e)
def _iterable(self, body):
sys_logging.DEBUG)
return app
- except (LookupError, ImportError), e:
+ except (LookupError, ImportError) as e:
raise RuntimeError("Unable to load %(app_name)s from "
"configuration file %(conf_file)s."
"\nGot: %(e)r" % locals())
def wrapped(*args, **kw):
try:
return f(*args, **kw)
- except Exception, e:
+ except Exception as e:
# Save exception since it can be clobbered during processing
# below before we can re-raise
exc_info = sys.exc_info()
if use_ssl:
sock = ssl.wrap_socket(sock, certfile=cert_file,
keyfile=key_file)
- except socket.error, err:
+ except socket.error as err:
if err.args[0] != errno.EADDRINUSE:
raise
eventlet.sleep(0.1)
self.logger.error(_('Removing dead child %s') % pid)
self.children.remove(pid)
self.run_child()
- except OSError, err:
+ except OSError as err:
if err.errno not in (errno.EINTR, errno.ECHILD):
raise
except KeyboardInterrupt:
custom_pool=self.pool,
url_length_limit=URL_LENGTH_LIMIT,
log=WritableLogger(self.logger))
- except socket.error, err:
+ except socket.error as err:
if err[0] != errno.EINVAL:
raise
self.pool.waitall()
session.add(self)
try:
session.flush()
- except IntegrityError, e:
+ except IntegrityError as e:
if str(e).endswith('is not unique'):
raise exception.Duplicate(str(e))
else:
def checkout(self, dbapi_con, con_record, con_proxy):
try:
dbapi_con.cursor().execute('select 1')
- except dbapi_con.OperationalError, ex:
+ except dbapi_con.OperationalError as ex:
if ex.args[0] in (2006, 2013, 2014, 2045, 2055):
logger.warn('Got mysql server has gone away: %s', ex)
raise DisconnectionError("Database server went away")
while True:
try:
self.sftp.stat('/var/lib/heat-cfntools/boot-finished')
- except IOError, e:
+ except IOError as e:
tries += 1
if e.errno == errno.ENOENT:
self.testcase.assertTrue(tries < 50, 'Timed out')
try:
# NOTE(vish): handle namespace modules
module = __import__(mod)
- except ImportError, exc:
+ except ImportError as exc:
# NOTE(vish): the import error might be due
# to a missing dependency
missing = str(exc).split()[-1]