Merge pull request #209 from biggraph/darabos-mcp-fixes

lynxkite-app/web/src/index.css

@@ -325,6 +325,7 @@ body {
   .table-viewer {
     td {
       padding: 5px 10px;
+      vertical-align: top;
     }
 
     .image-in-table {

lynxkite-core/src/lynxkite/core/ops.py

@@ -254,8 +254,8 @@ def op(
             _view = "image"
             func = matplotlib_to_image(func)
         if slow:
-            func = mem.cache(func)
             func = make_async(func)
+            func = mem.cache(func)
         # Positional arguments are inputs.
         inputs = [
             Input(name=name, type=param.annotation)
@@ -456,6 +456,7 @@ def parse_doc(func):
         return doc
     if doc is None:
         return None
+    griffe.logger.setLevel("ERROR")
     ds = griffe.Docstring(doc, parent=_get_griffe_function(func))
     if "----" in doc:
         ds = ds.parse("numpy")

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

@@ -52,7 +52,7 @@ class WorkspaceNode(BaseConfig):
         """Notifies the frontend that work has started on this node."""
         self.data.error = None
         self.data.status = NodeStatus.active
-        if hasattr(self, "_crdt"):
+        if hasattr(self, "_crdt") and "data" in self._crdt:
             with self._crdt.doc.transaction():
                 self._crdt["data"]["error"] = None
                 self._crdt["data"]["status"] = NodeStatus.active
@@ -63,7 +63,7 @@ class WorkspaceNode(BaseConfig):
         self.data.input_metadata = result.input_metadata
         self.data.error = result.error
         self.data.status = NodeStatus.done
-        if hasattr(self, "_crdt"):
+        if hasattr(self, "_crdt") and "data" in self._crdt:
             with self._crdt.doc.transaction():
                 try:
                     self._crdt["data"]["status"] = NodeStatus.done

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

@@ -227,13 +227,13 @@ async def _execute_node(
             if p.type == nx.Graph:
                 if isinstance(x, Bundle):
                     x = x.to_nx()
-                assert isinstance(x, nx.Graph), "Input must be a graph."
+                assert isinstance(x, nx.Graph), f"Input must be a graph. Got: {x}"
             elif p.type == Bundle:
                 if isinstance(x, nx.Graph):
                     x = Bundle.from_nx(x)
                 elif isinstance(x, pd.DataFrame):
                     x = Bundle.from_df(x)
-                assert isinstance(x, Bundle), "Input must be a graph or dataframe."
+                assert isinstance(x, Bundle), f"Input must be a graph or dataframe. Got: {x}"
             inputs.append(x)
     except Exception as e:
         if not os.environ.get("LYNXKITE_SUPPRESS_OP_ERRORS"):

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

@@ -156,7 +156,7 @@ def wrapped(name: str, func):
         for k, v in kwargs.items():
             if v == "None":
                 kwargs[k] = None
-        res = await ops.run_in_thread(func)(*args, **kwargs)
+        res = await ops.make_async(func)(*args, **kwargs)
         # Figure out what the returned value is.
         if isinstance(res, nx.Graph):
             return res