Fix interrupt handling for release

Author: eddmpython

CHANGELOG.md

@@ -27,6 +27,7 @@
 
 - Reduced false positives in document dependency analysis for nested scopes and comprehension variables.
 - Improved engine/runtime behavior around worker management, variables, and process lifecycle.
+- Stabilized soft interrupt handling so worker resets do not surface as connection-reset crashes in CI.
 - Cleaned frontend warning sources in dialog, toast, mode switcher, hint, guide, and widget surfaces.
 - Corrected the PyPI workflow to validate the adapter-static editor output in `src/codaro/webBuild` and run tests with the `dev` extra installed.
 

src/codaro/runtime/localWorker.py

@@ -65,16 +65,35 @@ def emitEvent(eventType: str, payload: Any = None) -> None:
                         },
                     )
 
-                response = _executeCommand(
-                    code=command["code"],
-                    blockId=blockId,
-                    injectedVars=command.get("injectedVars"),
-                    registry=registry,
-                    cellDefinitions=cellDefinitions,
-                    executionCount=executionCount,
-                    targetCwd=targetCwd,
-                    emitEvent=emitEvent,
-                )
+                try:
+                    response = _executeCommand(
+                        code=command["code"],
+                        blockId=blockId,
+                        injectedVars=command.get("injectedVars"),
+                        registry=registry,
+                        cellDefinitions=cellDefinitions,
+                        executionCount=executionCount,
+                        targetCwd=targetCwd,
+                        emitEvent=emitEvent,
+                    )
+                except KeyboardInterrupt:
+                    if interruptFlag is not None:
+                        interruptFlag.clear()
+                    response = _buildInterruptedResponse(registry, cellDefinitions, executionCount)
+                    emitEvent(
+                        "display",
+                        {
+                            "outputType": "error",
+                            "data": response["data"],
+                        },
+                    )
+                    emitEvent(
+                        "finished",
+                        {
+                            "status": response["status"],
+                            "outputType": response["type"],
+                        },
+                    )
                 _workerSend(connection, {"kind": "response", "response": response})
                 continue
 
@@ -239,6 +258,29 @@ def _buildStateResponse(
     }
 
 
+def _buildInterruptedResponse(
+    registry: dict[str, object],
+    cellDefinitions: dict[str, set[str]],
+    executionCount: int,
+) -> dict[str, Any]:
+    response = _buildStateResponse(registry, cellDefinitions, executionCount)
+    response["stateDelta"] = {
+        "added": [],
+        "updated": [],
+        "removed": [],
+    }
+    response.update(
+        {
+            "type": "error",
+            "data": "Execution interrupted.",
+            "stdout": "",
+            "stderr": "",
+            "status": "error",
+        }
+    )
+    return response
+
+
 def _buildRegistryMirror(registry: dict[str, object]) -> dict[str, object]:
     snapshot: dict[str, object] = {}
     for name, value in registry.items():
@@ -517,7 +559,7 @@ def _sanitizeDescriptor(value: object) -> object:
 
 def _installInterruptTrace(interruptFlag) -> None:
     def traceCallback(frame, event, arg):
-        if interruptFlag.is_set():
+        if interruptFlag.is_set() and frame.f_code.co_filename == "<codaro>":
             raise KeyboardInterrupt("Soft interrupt requested")
         return traceCallback
     sys.settrace(traceCallback)