X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=juju%2Futils.py;h=f4db66e723c850770b24ccfb90ce17484f72a517;hb=1a3cee44420e79fda92943edf636eaddb393145e;hp=9f5d63d1465232ad13dfa51db88324ed1ad098ac;hpb=f3e0df690919bb6413aee809bd9d6d295daa7cc8;p=osm%2FN2VC.git

diff --git a/juju/utils.py b/juju/utils.py
index 9f5d63d..f4db66e 100644
--- a/juju/utils.py
+++ b/juju/utils.py
@@ -59,7 +59,13 @@ class IdQueue:
     async def get(self, id):
         value = await self._queues[id].get()
         del self._queues[id]
+        if isinstance(value, Exception):
+            raise value
         return value
 
     async def put(self, id, value):
         await self._queues[id].put(value)
+
+    async def put_all(self, value):
+        for queue in self._queues.values():
+            await queue.put(value)