X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=juju%2Fclient%2Fconnection.py;h=3ee8f16c914bc7052f4583f41b02de6b4470a7b6;hb=502464d629d4e525e0ba68e8dbdf5632b3808596;hp=b9eb3bcdc30e97f25be3a2d1c1fca0a824e6f1dd;hpb=fe64744d4eb7d1b989b24d6178929793de57a7d5;p=osm%2FN2VC.git

diff --git a/juju/client/connection.py b/juju/client/connection.py
index b9eb3bc..3ee8f16 100644
--- a/juju/client/connection.py
+++ b/juju/client/connection.py
@@ -97,9 +97,11 @@ class Connection:
                     await self.messages.put(result['request-id'], result)
             except Exception as e:
                 await self.messages.put_all(e)
+                if isinstance(e, websockets.ConnectionClosed):
+                    # ConnectionClosed is not really exceptional for us,
+                    # but it may be for any pending message listeners
+                    return
                 raise
-        await self.messages.put_all(websockets.exceptions.ConnectionClosed(
-            0, 'websocket closed'))
 
     async def rpc(self, msg, encoder=None):
         self.__request_id__ += 1