Small fixes. The CSS import order caused connectors to be tiny.

lynxkite-app/README.md

@@ -12,8 +12,8 @@ original LynxKite. The primary goals of this rewrite are:
 To run the backend:
 
 ```bash
-PYTHONPATH=. uv run pydantic2ts --module server.workspace --output ./web/src/apiTypes.ts --json2ts-cmd "npm exec --prefix web json2ts"
-uv run fastapi run server/main.py --reload
+uv pip install -e .
+LYNXKITE_RELOAD=1 lynxkite
 ```
 
 To run the frontend:

lynxkite-app/uv.lock

@@ -212,7 +212,7 @@ version = "0.1.0"
 source = { editable = "." }
 dependencies = [
     { name = "fastapi", extra = ["standard"] },
-    { name = "lynxkite-ops" },
+    { name = "lynxkite-core" },
     { name = "orjson" },
     { name = "pycrdt-websocket" },
     { name = "pydantic-to-typescript" },
@@ -222,7 +222,7 @@ dependencies = [
 [package.metadata]
 requires-dist = [
     { name = "fastapi", extras = ["standard"], specifier = ">=0.115.6" },
-    { name = "lynxkite-ops", virtual = "../lynxkite-ops" },
+    { name = "lynxkite-core", virtual = "../lynxkite-core" },
     { name = "orjson", specifier = ">=3.10.13" },
     { name = "pycrdt-websocket", specifier = ">=0.15.3" },
     { name = "pydantic-to-typescript", specifier = ">=2.0.0" },
@@ -230,9 +230,9 @@ requires-dist = [
 ]
 
 [[package]]
-name = "lynxkite-ops"
+name = "lynxkite-core"
 version = "0.1.0"
-source = { virtual = "../lynxkite-ops" }
+source = { virtual = "../lynxkite-core" }
 
 [[package]]
 name = "markdown-it-py"

lynxkite-app/web/src/main.tsx

@@ -1,5 +1,6 @@
 import { StrictMode } from 'react'
 import { createRoot } from 'react-dom/client'
+import '@xyflow/react/dist/style.css';
 import './index.css'
 import Directory from './Directory.tsx'
 import Workspace from './workspace/Workspace.tsx'

lynxkite-app/web/src/workspace/Workspace.tsx

@@ -65,7 +65,6 @@ function LynxKiteFlow() {
         if (!state.workspace) return;
         if (!state.workspace.nodes) return;
         if (!state.workspace.edges) return;
-        console.log('update', JSON.parse(JSON.stringify(state.workspace)));
         setNodes([...state.workspace.nodes] as Node[]);
         setEdges([...state.workspace.edges] as Edge[]);
         for (const node of state.workspace.nodes) {
@@ -121,7 +120,6 @@ function LynxKiteFlow() {
     const wedges = state.workspace?.edges;
     if (!wedges) return;
     for (const ch of changes) {
-      console.log('edge change', ch);
       const edgeIndex = wedges.findIndex((e) => e.id === ch.id);
       if (ch.type === 'remove') {
         wedges.splice(edgeIndex, 1);
@@ -195,7 +193,6 @@ function LynxKiteFlow() {
       target: connection.target,
       targetHandle: connection.targetHandle!,
     };
-    console.log(JSON.stringify(edge));
     state.workspace.edges!.push(edge);
     setEdges((oldEdges) => [...oldEdges, edge]);
   }, [state, setEdges]);

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

@@ -8,7 +8,6 @@ const NodeWithVisualization = (props: any) => {
   useEffect(() => {
     const opts = props.data?.display?.value;
     if (!opts || !chartsRef.current) return;
-    console.log(chartsRef.current);
     chartsInstanceRef.current = echarts.init(chartsRef.current, null, { renderer: 'canvas', width: 250, height: 250 });
     chartsInstanceRef.current.setOption(opts);
     const onResize = () => chartsInstanceRef.current?.resize();
@@ -20,7 +19,7 @@ const NodeWithVisualization = (props: any) => {
   }, [props.data?.display?.value]);
   return (
     <NodeWithParams {...props}>
-      <div className="box" draggable={false} ref={chartsRef} />;
+      <div className="box" draggable={false} ref={chartsRef} />
     </NodeWithParams>
   );
 };

lynxkite-graph-analytics/src/lynxkite_plugins/graph_analytics/lynxkite_ops.py

@@ -12,7 +12,8 @@ import polars as pl
 import traceback
 import typing
 
-op = ops.op_registration("LynxKite Graph Analytics")
+ENV = "LynxKite Graph Analytics"
+op = ops.op_registration(ENV)
 
 
 @dataclasses.dataclass
@@ -112,9 +113,9 @@ def disambiguate_edges(ws):
         seen.add((edge.target, edge.targetHandle))
 
 
-@ops.register_executor("LynxKite")
+@ops.register_executor(ENV)
 async def execute(ws):
-    catalog = ops.CATALOGS["LynxKite"]
+    catalog = ops.CATALOGS[ENV]
     disambiguate_edges(ws)
     outputs = {}
     failed = 0

lynxkite-graph-analytics/src/lynxkite_plugins/graph_analytics/networkx_ops.py

@@ -5,6 +5,8 @@ import functools
 import inspect
 import networkx as nx
 
+ENV = "LynxKite Graph Analytics"
+
 
 def wrapped(name: str, func):
     @functools.wraps(func)
@@ -24,7 +26,7 @@ def wrapped(name: str, func):
 
 
 def register_networkx(env: str):
-    ops.CATALOGS.setdefault(env, {})
+    cat = ops.CATALOGS.setdefault(env, {})
     for name, func in nx.__dict__.items():
         if hasattr(func, "graphs"):
             sig = inspect.signature(func)
@@ -54,7 +56,7 @@ def register_networkx(env: str):
                 outputs={"output": ops.Output(name="output", type=nx.Graph)},
                 type="basic",
             )
-            ops.CATALOGS[env][name] = op
+            cat[name] = op
 
 
-register_networkx("LynxKite")
+register_networkx(ENV)