Update src/frequenz/client/base/streaming.py

Co-authored-by: Copilot <[email protected]>
Signed-off-by: Mathias L. Baumann <[email protected]>

Author: Marenz

src/frequenz/client/base/streaming.py

@@ -88,6 +88,10 @@ def reconnect(self) -> None:
                 self._stream_name,
             )
             self._task.cancel()
+            try:
+                await self._task
+            except asyncio.CancelledError:
+                pass
         self._task = asyncio.create_task(self._run())
 
     @property