Implement batch events for RemotePregel

2026-08-30 19:59:40 +02:00 · 2025-03-19 14:22:04 +01:00
parent b7fb8e6afb
commit 68a5c3f4c7
1 changed files with 14 additions and 0 deletions
@@ -457,6 +457,20 @@ class RemoteGraph(PregelProtocol):
        for state in states:
            yield self._create_state_snapshot(state)

+    def bulk_update_state(
+        self,
+        config: RunnableConfig,
+        updates: list[tuple[Optional[dict[str, Any]], Optional[str]]],
+    ) -> RunnableConfig:
+        raise NotImplementedError
+
+    async def abulk_update_state(
+        self,
+        config: RunnableConfig,
+        updates: list[tuple[Optional[dict[str, Any]], Optional[str]]],
+    ) -> RunnableConfig:
+        raise NotImplementedError
+
    def update_state(
        self,
        config: RunnableConfig,