sq-poller: raise unhandled tasks exceptions

Signed-off-by: Claudio Lorina <[email protected]>

Author: claudiolor

suzieq/poller/worker/worker.py

@@ -138,8 +138,11 @@ async def run(self):
             tasks = await self._pop_waiting_worker_tasks()
             while tasks:
                 try:
-                    _, pending = await asyncio.wait(
+                    done, pending = await asyncio.wait(
                         tasks, return_when=asyncio.FIRST_COMPLETED)
+                    for d in done:
+                        if d.exception():
+                            raise d.exception()
                     tasks = list(pending)
                     running_svcs = self.service_manager.running_services
                     if tasks and any(i._coro in running_svcs