Tri-state status. Nicer visuals.

lynxkite-app/src/lynxkite_app/crdt.py

@@ -86,7 +86,7 @@ def clean_input(ws_pyd):
     for node in ws_pyd.nodes:
         node.data.display = None
         node.data.error = None
-        node.data.in_progress = False
+        node.data.status = workspace.NodeStatus.done
         node.position.x = 0
         node.position.y = 0
         if node.model_extra:
@@ -228,7 +228,7 @@ async def execute(
         for nc, np in zip(ws_crdt["nodes"], ws_pyd.nodes):
             if "data" not in nc:
                 nc["data"] = pycrdt.Map()
-            nc["data"]["in_progress"] = True
+            nc["data"]["status"] = "planned"
             # Nodes get a reference to their CRDT maps, so they can update them as the results come in.
             np._crdt = nc
     await workspace.execute(ws_pyd)

lynxkite-app/web/src/index.css

@@ -94,8 +94,19 @@ body {
     padding: 8px;
   }
 
-  .lynxkite-node .title.in-progress {
-    background: yellow;
+  .lynxkite-node .title.active {
+    background: linear-gradient(
+      to right,
+      oklch(75% 0.2 55),
+      oklch(90% 0.2 55),
+      oklch(75% 0.1 55)
+    );
+    background-size: 180% 180%;
+    animation: active-node-gradient-animation 2s ease-in-out infinite;
+  }
+
+  .lynxkite-node .title.planned {
+    background: oklch(75% 0.1 55);
   }
 
   .handle-name {
@@ -325,6 +336,20 @@ body {
   }
 }
 
+@keyframes active-node-gradient-animation {
+  0% {
+    background-position-x: 100%;
+  }
+
+  50% {
+    background-position-x: 0%;
+  }
+
+  100% {
+    background-position-x: 100%;
+  }
+}
+
 .react-flow__edge.selected path.react-flow__edge-path {
   outline: var(--xy-selection-border, var(--xy-selection-border-default));
   outline-offset: 10px;

lynxkite-app/web/src/workspace/nodes/LynxKiteNode.tsx

@@ -72,7 +72,7 @@ export default function LynxKiteNode(props: LynxKiteNodeProps) {
     >
       <div className="lynxkite-node" style={props.nodeStyle}>
         <div
-          className={`title bg-primary ${data.in_progress ? "in-progress" : ""}`}
+          className={`title bg-primary ${data.status}`}
           onClick={titleClicked}
         >
           {data.title}

lynxkite-core/src/lynxkite/core/workspace.py

@@ -3,6 +3,7 @@
 import json
 from typing import Optional
 import dataclasses
+import enum
 import os
 import pycrdt
 import pydantic
@@ -21,12 +22,18 @@ class Position(BaseConfig):
     y: float
 
 
+class NodeStatus(str, enum.Enum):
+    planned = "planned"
+    active = "active"
+    done = "done"
+
+
 class WorkspaceNodeData(BaseConfig):
     title: str
     params: dict
     display: Optional[object] = None
     error: Optional[str] = None
-    in_progress: bool = False
+    status: NodeStatus = NodeStatus.done
     # Also contains a "meta" field when going out.
     # This is ignored when coming back from the frontend.
 
@@ -40,16 +47,22 @@ class WorkspaceNode(BaseConfig):
     position: Position
     _crdt: pycrdt.Map
 
+    def publish_started(self):
+        """Notifies the frontend that work has started on this node."""
+        self.data.status = NodeStatus.active
+        if hasattr(self, "_crdt"):
+            self._crdt["data"]["status"] = NodeStatus.active
+
     def publish_result(self, result: ops.Result):
         """Sends the result to the frontend. Call this in an executor when the result is available."""
         self.data.display = result.display
         self.data.error = result.error
-        self.data.in_progress = False
+        self.data.status = NodeStatus.done
         if hasattr(self, "_crdt"):
             with self._crdt.doc.transaction():
                 self._crdt["data"]["display"] = result.display
                 self._crdt["data"]["error"] = result.error
-                self._crdt["data"]["in_progress"] = False
+                self._crdt["data"]["status"] = NodeStatus.done
 
     def publish_error(self, error: Exception | str):
         self.publish_result(ops.Result(error=str(error)))

lynxkite-graph-analytics/src/lynxkite_graph_analytics/core.py

@@ -164,6 +164,7 @@ async def execute(ws):
                     node.publish_error("Operation not found in catalog")
                     failed += 1
                     continue
+                node.publish_started()
                 try:
                     # Convert inputs types  to match operation signature.
                     for i, (x, p) in enumerate(zip(inputs, op.inputs.values())):