Forráskód Böngészése

修正运行时错误

dongzhaorui 11 hónapja
szülő
commit
de7070599e

+ 2 - 3
FworkSpider/feapder/buffer/item_buffer/jy_item_buffer.py

@@ -286,9 +286,8 @@ class JyItemBuffer(threading.Thread):
         release_tasks = []
         if not finished:
             token = datas["token"]
-            for item in self.tasks_dict["data"]:
-                data = datas["data"].pop(item["pyuuid"])
-                release_tasks.append(data)
+            for pyuuid in dict(self.tasks_dict["data"]):
+                release_tasks.append(datas["data"].pop(pyuuid))
         else:
             token = self.tasks_dict["token"]
             target_pyuuid_lst = [data["pyuuid"] for data in datas]