Improve cleanup of un-awaited coroutines in MockMicrogrid

The coros and tasks can all be removed as soon as the benchmark
scripts have their own framework, this is just until that point.

Signed-off-by: Sahas Subramanian <[email protected]>

Author: shsms

tests/timeseries/mock_microgrid.py

@@ -440,6 +440,9 @@ async def cleanup(self) -> None:
         if _data_pipeline._DATA_PIPELINE:
             await _data_pipeline._DATA_PIPELINE._stop()
 
+        for coro in self._streaming_coros:
+            coro.close()
+
         for task in self._streaming_tasks:
             await cancel_and_await(task)
         microgrid.connection_manager._CONNECTION_MANAGER = None