Move Pandas import from lynxkite-app to lynxkite-graph-analytics.

lynxkite-app/src/lynxkite_app/main.py

@@ -1,11 +1,9 @@
 """The FastAPI server for serving the LynxKite application."""
 
-import os
 import shutil
 import pydantic
 import fastapi
 import importlib
-import pandas as pd
 import pathlib
 import pkgutil
 from fastapi.staticfiles import StaticFiles
@@ -14,13 +12,6 @@ from lynxkite.core import ops
 from lynxkite.core import workspace
 from . import crdt, config
 
-if os.environ.get("NX_CUGRAPH_AUTOCONFIG", "").strip().lower() == "true":
-    import cudf.pandas
-
-    cudf.pandas.install()
-
-pd.options.mode.copy_on_write = True  # Prepare for Pandas 3.0.
-
 
 def detect_plugins():
     plugins = {}

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

@@ -42,10 +42,14 @@ class WorkspaceNode(BaseConfig):
 
     def publish_result(self, result: ops.Result):
         """Sends the result to the frontend. Call this in an executor when the result is available."""
-        with self._crdt.doc.transaction():
-            self._crdt["data"]["display"] = result.display
-            self._crdt["data"]["error"] = result.error
-            self._crdt["data"]["in_progress"] = False
+        self.data.display = result.display
+        self.data.error = result.error
+        self.data.in_progress = False
+        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
 
     def publish_error(self, error: Exception | str):
         self.publish_result(ops.Result(error=str(error)))

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

@@ -1,3 +1,15 @@
+"""Graph analytics environment for LynxKite. The core types and functions are imported here for easy access."""
+
+import os
+import pandas as pd
+
+if os.environ.get("NX_CUGRAPH_AUTOCONFIG", "").strip().lower() == "true":
+    import cudf.pandas
+
+    cudf.pandas.install()
+
+pd.options.mode.copy_on_write = True  # Prepare for Pandas 3.0.
+
 from .core import *  # noqa (easier access for core classes)
 from . import lynxkite_ops  # noqa (imported to trigger registration)
 from . import networkx_ops  # noqa (imported to trigger registration)