리액티브 실행 payload에 진단·stale·의존 인접 동봉

KernelReactivePayload에 multipleDefinitions·crossCellMutations·staleBlockIds·dependents 추가
(기본값 비움 = 하위호환). executeKernelReactive가 그래프를 1회만 빌드해 진단을 모으고, 에러로
실행 못 한 다운스트림을 staleBlockIds로 표시. httpPayload·wsCompletePayload 직렬화 통일.
remove-cell 엔드포인트 라운드트립 테스트 추가.

Author: eddmpython

src/codaro/kernel/executionPayload.py

@@ -6,7 +6,7 @@
 from typing import Any
 
 from .protocol import ExecutionEvent, ExecutionOutput, WsResultMessage
-from .reactive import executeReactive, previewReactiveOrder, reactiveDiagnostics
+from .reactive import buildReactiveGraph, diagnosticsFromGraph, executeReactive, previewReactiveOrder
 from .session import KernelSession
 
 
@@ -28,6 +28,10 @@ class KernelReactivePayload:
     executionOrder: tuple[str, ...]
     durationMs: float
     cycles: tuple[tuple[str, ...], ...] = ()
+    multipleDefinitions: tuple[tuple[str, tuple[str, ...]], ...] = ()
+    crossCellMutations: tuple[tuple[str, str, str], ...] = ()
+    staleBlockIds: tuple[str, ...] = ()
+    dependents: tuple[tuple[str, tuple[str, ...]], ...] = ()
 
     @property
     def resultCount(self) -> int:
@@ -37,11 +41,20 @@ def resultCount(self) -> int:
     def executionCount(self) -> int:
         return len(self.executionOrder)
 
+    def _diagnosticsPayload(self) -> dict[str, Any]:
+        return {
+            "cycles": [list(cycle) for cycle in self.cycles],
+            "multipleDefinitions": [[var, list(blockIds)] for var, blockIds in self.multipleDefinitions],
+            "crossCellMutations": [list(mutation) for mutation in self.crossCellMutations],
+            "staleBlockIds": list(self.staleBlockIds),
+            "dependents": {blockId: list(downstream) for blockId, downstream in self.dependents},
+        }
+
     def httpPayload(self) -> dict[str, Any]:
         return {
             "results": [result.model_dump() for result in self.results],
             "executionOrder": list(self.executionOrder),
-            "cycles": [list(cycle) for cycle in self.cycles],
+            **self._diagnosticsPayload(),
         }
 
     def toolPayload(self) -> dict[str, Any]:
@@ -67,7 +80,7 @@ def wsCompletePayload(self, requestId: str) -> dict[str, Any]:
             "type": "reactiveComplete",
             "requestId": requestId,
             "executionOrder": list(self.executionOrder),
-            "cycles": [list(cycle) for cycle in self.cycles],
+            **self._diagnosticsPayload(),
         }
 
 
@@ -93,15 +106,28 @@ async def executeKernelReactive(
 ) -> KernelReactivePayload:
     startedAt = time.perf_counter()
     blockList = list(blocks)
-    cycles = reactiveDiagnostics(blockList)
+    graph = buildReactiveGraph(blockList)
+    diagnostics = diagnosticsFromGraph(graph)
     results, executionOrder = await executeReactive(
-        session, blockList, changedBlockId, eventHandler=eventHandler, includeSource=includeSource
+        session, blockList, changedBlockId, eventHandler=eventHandler, includeSource=includeSource, graph=graph
+    )
+    # early-stop(에러로 중단)으로 영향받았지만 실행 못 한 셀 = stale.
+    executed = {result.blockId for result in results}
+    staleBlockIds = tuple(blockId for blockId in executionOrder if blockId not in executed)
+    dependents = tuple(
+        (blockId, tuple(sorted(graph.dependents[blockId])))
+        for blockId in graph.blockOrder
+        if graph.dependents.get(blockId)
     )
     return KernelReactivePayload(
         results=tuple(results),
         executionOrder=tuple(executionOrder),
         durationMs=_durationMs(startedAt),
-        cycles=tuple(tuple(cycle) for cycle in cycles),
+        cycles=diagnostics.cycles,
+        multipleDefinitions=diagnostics.multipleDefinitions,
+        crossCellMutations=diagnostics.crossCellMutations,
+        staleBlockIds=staleBlockIds,
+        dependents=dependents,
     )
 
 

tests/testKernel.py

@@ -185,6 +185,10 @@ def testReactivePayloadOwnsHttpWsAndToolShapes() -> None:
         "requestId": "req-r",
         "executionOrder": ["b1", "b2"],
         "cycles": [],
+        "multipleDefinitions": [],
+        "crossCellMutations": [],
+        "staleBlockIds": [],
+        "dependents": {"b1": ["b2"]},
     }
 
     toolPayload = payload.toolPayload()
@@ -194,6 +198,21 @@ def testReactivePayloadOwnsHttpWsAndToolShapes() -> None:
     session.dispose()
 
 
+def testReactivePayloadMarksUnrunDownstreamStaleOnError() -> None:
+    session = KernelSession()
+    blocks = [
+        {"id": "a", "type": "code", "content": "x = 1"},
+        {"id": "b", "type": "code", "content": "y = x + missing"},  # NameError → early stop
+        {"id": "c", "type": "code", "content": "z = y + 1"},
+    ]
+    payload = _run(executeKernelReactive(session, blocks, "a"))
+
+    assert payload.executionOrder == ("a", "b", "c")
+    # b가 에러로 끊겨 c는 실행 못 함 → stale.
+    assert payload.staleBlockIds == ("c",)
+    session.dispose()
+
+
 def testMultilineCode() -> None:
     session = KernelSession()
     code = """

tests/testServerApi.py

@@ -134,6 +134,23 @@ def testKernelStatePersistence() -> None:
     client.delete(f"/api/kernel/{sessionId}")
 
 
+def testKernelRemoveCellEndpointClearsDefinitions() -> None:
+    client = TestClient(createServerApp())
+    sessionId = client.post("/api/kernel/create", json={}).json()["sessionId"]
+
+    client.post(f"/api/kernel/{sessionId}/execute", json={"code": "x = 10", "blockId": "a"})
+    removeResponse = client.post(f"/api/kernel/{sessionId}/remove-cell", json={"code": "", "blockId": "a"})
+    assert removeResponse.status_code == 200
+    assert removeResponse.json() == {"status": "removed"}
+
+    # 삭제 후 x를 참조하면 NameError(zombie 없음).
+    result = client.post(f"/api/kernel/{sessionId}/execute", json={"code": "x + 1", "blockId": "b"})
+    assert result.json()["status"] == "error"
+    assert "NameError" in f"{result.json()['data']} {result.json()['stderr']}"
+
+    client.delete(f"/api/kernel/{sessionId}")
+
+
 def testKernelReset() -> None:
     client = TestClient(createServerApp())
 
@@ -884,6 +901,10 @@ def testKernelWebSocketReactiveAndReset() -> None:
             "requestId": "req-reactive",
             "executionOrder": ["b1", "b2"],
             "cycles": [],
+            "multipleDefinitions": [],
+            "crossCellMutations": [],
+            "staleBlockIds": [],
+            "dependents": {"b1": ["b2"]},
         }
         assert websocket.receive_json() == {"type": "status", "engineStatus": "ready"}