raise TimeoutException from exceptions not api

This commit is contained in:
Terry Wilson 2017-02-27 12:39:01 -06:00
parent 27c733e281
commit 0602f6e38e
1 changed files with 4 additions and 4 deletions

View File

@ -61,8 +61,8 @@ class Transaction(api.Transaction):
try:
result = self.results.get(timeout=self.timeout)
except Queue.Empty:
raise api.TimeoutException(commands=self.commands,
timeout=self.timeout)
raise exceptions.TimeoutException(commands=self.commands,
timeout=self.timeout)
if isinstance(result, idlutils.ExceptionResult):
if self.log_errors:
LOG.error(result.tb)
@ -159,8 +159,8 @@ class NeutronOVSDBTransaction(Transaction):
self.api.idl.wait(self.ovsdb_connection.poller)
self.ovsdb_connection.poller.block()
else:
raise api.TimeoutException(commands=self.commands,
timeout=self.timeout)
raise exceptions.TimeoutException(commands=self.commands,
timeout=self.timeout)
def post_commit_failed_interfaces(self, txn):
failed = []