fix 1187 create notification task with the proper loop
Also call notifications when there are subscribers
Change-Id: Icf6b4f88aaf633282c2736de85803f845b17d4c6
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>
diff --git a/osm_nbi/notifications.py b/osm_nbi/notifications.py
index 9156c2c..2e7ba94 100644
--- a/osm_nbi/notifications.py
+++ b/osm_nbi/notifications.py
@@ -133,11 +133,13 @@
.format(subscriber["subscriptionId"],
subscriber["authentication"]["authType"]))
- tasks = []
- async with aiohttp.ClientSession(loop=loop) as session:
- for notification in notifications:
- tasks.append(asyncio.ensure_future(self.send_notification(session, notification, loop=loop), loop=loop))
- await asyncio.gather(*tasks, loop=loop)
+ if notifications:
+ tasks = []
+ async with aiohttp.ClientSession(loop=loop) as session:
+ for notification in notifications:
+ tasks.append(asyncio.ensure_future(self.send_notification(session, notification, loop=loop),
+ loop=loop))
+ await asyncio.gather(*tasks, loop=loop)
async def send_notification(self, session: aiohttp.ClientSession, notification: dict,
loop: asyncio.AbstractEventLoop = None, retry_count: int = 5, timeout: float = 5.0):