reconnect fix

SiriDB · Feb 10, 2023 · 839626b · 839626b
1 parent 6b57f82
commit 839626b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/siridb/__init__.py b/siridb/__init__.py
@@ -1,4 +1,4 @@
-__version_info__ = (2, 1, 1)
+__version_info__ = (2, 1, 2)
 __version__ = '.'.join(map(str, __version_info__))
 __maintainer__ = 'Jeroen van der Heijden'
 __email__ = '[email protected]'
diff --git a/siridb/connector/lib/client.py b/siridb/connector/lib/client.py
@@ -464,8 +464,9 @@ async def _ensure_write(
                 if retry > self.MAX_WRITE_RETRY:
                     raise e
                 if retry % self.RECONNECT_ATTEMPT == 0:
-                    self._reconnect()
-                await asyncio.sleep(1.0)
+                    await self._reconnect()
+                else:
+                    await asyncio.sleep(1.0)
                 continue
 
             return res