feat: sync di_graph_repository

metagpt/utils/di_graph_repository.py

@@ -82,28 +82,12 @@ async def delete(self, subject: str = None, predicate: str = None, object_: str
             deleted_count = await my_di_graph_repo.delete(subject="Node1", predicate="connects_to")
             # Deletes directed relationships where Node1 is the subject and the predicate is 'connects_to'.
         """
-        rows = []
-        for s, o, p in self._repo.edges(data="predicate"):
-            if subject and subject != s:
-                continue
-            if object_ and object_ != o:
-                continue
-            rows.append(SPO(subject=s, object_=o, predicate=p))
+        rows = await self.select(subject=subject, predicate=predicate, object_=object_)
         if not rows:
             return 0
-
-        affected = []
-        unaffected = []
         for r in rows:
             self._repo.remove_edge(r.subject, r.object_)
-            if predicate and predicate == r.predicate:
-                affected.append(r)
-            else:
-                unaffected.append(r)
-
-        for r in unaffected:
-            self._repo.add_edge(r.subject, r.object_, predicate=r.predicate)
-        return len(affected)
+        return len(rows)
 
     def json(self) -> str:
         """Convert the directed graph repository to a JSON-formatted string."""

tests/metagpt/actions/requirement_analysis/summarize/test_summarize.py

@@ -6,7 +6,7 @@
 
 @pytest.mark.asyncio
 async def test_summarize(context):
-    await prepare_graph_db()
+    await prepare_graph_db(context)
 
     action = Summarize(context=context)
     await action.run()