cancel tasks

Author: gtfierro

buildingmotif/ingresses/bacnet.py

@@ -64,6 +64,13 @@ def _run_async(self, coro):
         try:
             asyncio.set_event_loop(loop)
             loop.run_until_complete(coro)
+            pending = [task for task in asyncio.all_tasks(loop) if not task.done()]
+            if pending:
+                for task in pending:
+                    task.cancel()
+                loop.run_until_complete(
+                    asyncio.gather(*pending, return_exceptions=True)
+                )
             loop.run_until_complete(loop.shutdown_asyncgens())
         finally:
             asyncio.set_event_loop(None)