修复93说的并发

Author: tianxiu2b2t

core/cluster.py

@@ -239,8 +239,8 @@ async def error(*responses: aiohttp.ClientResponse):
                 content: io.BytesIO = io.BytesIO()
                 resp = None
                 try:
-                    #async with lock:
-                    resp = await session.get(file.path)
+                    async with lock:
+                        resp = await session.get(file.path)
                     while data := await resp.content.read(IO_BUFFER):
                         if not data:
                             break