refactor: close stream

long2ice · Dec 27, 2023 · 7df4fcc · 7df4fcc
1 parent ea83853
commit 7df4fcc
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/meilisync/source/mysql.py b/meilisync/source/mysql.py
@@ -121,6 +121,7 @@ async def __aiter__(self):
             except OperationalError as e:
                 logger.exception(f"Binlog stream error: {e}, sleep 10s and retry...")
                 await asyncio.sleep(10)
+                await self.stream.close()
                 await self._create_stream()
 
     async def __aexit__(self, exc_type, exc_val, exc_tb):