From 2e327070a1703ef7adabc785c741631b0fc5ea96 Mon Sep 17 00:00:00 2001 From: Benjamin Himes Date: Tue, 29 Jul 2025 18:22:51 +0200 Subject: [PATCH] This should fix the concurrencyerrors --- async_substrate_interface/async_substrate.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/async_substrate_interface/async_substrate.py b/async_substrate_interface/async_substrate.py index fc4f034..efe1985 100644 --- a/async_substrate_interface/async_substrate.py +++ b/async_substrate_interface/async_substrate.py @@ -613,9 +613,10 @@ async def connect(self, force=False): self.ws = await asyncio.wait_for( connect(self.ws_url, **self._options), timeout=10.0 ) - self._receiving_task = asyncio.get_running_loop().create_task( - self._start_receiving() - ) + if self._receiving_task is None or self._receiving_task.done(): + self._receiving_task = asyncio.get_running_loop().create_task( + self._start_receiving() + ) self._initialized = True finally: self._is_connecting = False