Duh

python-trio · Aug 3, 2019 · f9acda3 · f9acda3
1 parent c65722d
commit f9acda3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/asyncamqp/channel.py b/asyncamqp/channel.py
@@ -15,7 +15,7 @@
 from . import exceptions
 from .envelope import Envelope, ReturnEnvelope
 from .future import Future
-from .exceptions import AmqpClosedConnection
+from .exceptions import AmqpClosedConnection, SynchronizationError
 
 logger = logging.getLogger(__name__)
 
@@ -293,7 +293,7 @@ async def close(self, reply_code=0, reply_text="Normal Shutdown"):
     async def close_ok(self, frame):
         try:
             w = self._get_waiter('close')
-        except asyncamqp.exceptions.SynchronizationError:
+        except SynchronizationError:
             pass
         else:
             await w.set_result(True)