refactor: close stream

long2ice · Dec 27, 2023 · 4676fa4 · 4676fa4
1 parent e18b47c
commit 4676fa4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/meilisync/source/mysql.py b/meilisync/source/mysql.py
@@ -122,7 +122,7 @@ async def __aiter__(self):
                 logger.exception(f"Binlog stream error: {e}, sleep 10s and retry...")
                 await asyncio.sleep(10)
                 await self.stream.close()
-                await self.ctl_conn.close()
+                self.ctl_conn.close()
                 await self._create_stream()
 
     async def __aexit__(self, exc_type, exc_val, exc_tb):