Find plugins by module name instead of namespace module.

README.md

@@ -24,14 +24,13 @@ Install everything like this:
 uv venv
 source .venv/bin/activate
 # The [dev] tag is only needed if you intend on running tests
-uv pip install -e lynxkite-core/[dev] lynxkite-app/[dev] lynxkite-graph-analytics/[dev] lynxkite-lynxscribe/ lynxkite-pillow-example/
+uv pip install -e lynxkite-core/[dev] -e lynxkite-app/[dev] -e lynxkite-graph-analytics/[dev] -e lynxkite-lynxscribe/ -e lynxkite-pillow-example/
 ```
 
 This also builds the frontend, hopefully very quickly. To run it:
 
 ```bash
-cd lynxkite-app # just because the "data" directory with the examples is here
-LYNXKITE_RELOAD=1 lynxkite
+LYNXKITE_DATA=examples LYNXKITE_RELOAD=1 lynxkite
 ```
 
 If you also want to make changes to the frontend with hot reloading:

lynxkite-app/README.md

@@ -13,7 +13,7 @@ To run the backend:
 
 ```bash
 uv pip install -e .
-LYNXKITE_RELOAD=1 lynxkite
+LYNXKITE_DATA=../examples LYNXKITE_RELOAD=1 lynxkite
 ```
 
 To run the frontend:

lynxkite-app/pyproject.toml

@@ -15,7 +15,7 @@ dependencies = [
 
 [project.optional-dependencies]
 dev = [
-    "pytest",
+    "pytest>=8.3.4",
 ]
 
 [tool.uv.sources]
@@ -30,8 +30,8 @@ namespaces = true
 where = ["src"]
 
 [tool.setuptools.package-data]
-"lynxkite.app.web_assets" = ["*"]
-"lynxkite.app.web_assets.assets" = ["*"]
+"lynxkite_app.web_assets" = ["*"]
+"lynxkite_app.web_assets.assets" = ["*"]
 
 [tool.setuptools]
 py-modules = ["build_frontend"]
@@ -41,4 +41,4 @@ include-package-data = true
 build_py = "build_frontend.build_py"
 
 [project.scripts]
-lynxkite = "lynxkite.app.__main__:main"
+lynxkite = "lynxkite_app.__main__:main"

lynxkite-app/src/build_frontend.py

@@ -11,7 +11,7 @@ class build_py(_build_py):
         print("\n\nBuilding frontend...", __file__)
         here = Path(__file__).parent.parent
         frontend_dir = here / "web"
-        package_dir = here / "src" / "lynxkite" / "app" / "web_assets"
+        package_dir = here / "src" / "lynxkite_app" / "web_assets"
         subprocess.check_call(["npm", "install"], cwd=frontend_dir)
         subprocess.check_call(["npm", "run", "build"], cwd=frontend_dir)
         print("files in", frontend_dir / "dist")

lynxkite-app/src/lynxkite/app/web_assets/__init__.py

@@ -1 +0,0 @@
-"""The build process (uv build) puts the frontend build artifacts here."""

lynxkite-app/src/lynxkite/app/web_assets/assets/__init__.py

@@ -1 +0,0 @@
-"""More frontend build artifacts."""

lynxkite-app/src/{lynxkite/app → lynxkite_app}/__main__.py

@@ -6,7 +6,7 @@ import os
 def main():
     port = int(os.environ.get("PORT", "8000"))
     reload = bool(os.environ.get("LYNXKITE_RELOAD", ""))
-    uvicorn.run("lynxkite.app.main:app", host="0.0.0.0", port=port, reload=reload)
+    uvicorn.run("lynxkite_app.main:app", host="0.0.0.0", port=port, reload=reload)
 
 
 if __name__ == "__main__":

lynxkite-app/src/{lynxkite/app → lynxkite_app}/main.py

@@ -1,5 +1,8 @@
+"""The FastAPI server for serving the LynxKite application."""
+
 import os
 import shutil
+
 if os.environ.get("NX_CUGRAPH_AUTOCONFIG", "").strip().lower() == "true":
     import cudf.pandas
 
@@ -17,19 +20,13 @@ from . import crdt
 
 
 def detect_plugins():
-    try:
-        import lynxkite_plugins
-    except ImportError:
-        print("No modules found in lynxkite_plugins. Be sure to install some plugins.")
-        return {}
-
     plugins = {}
-    for _, name, _ in pkgutil.iter_modules(lynxkite_plugins.__path__):
-        name = f"lynxkite_plugins.{name}"
-        print(f"Importing {name}")
-        plugins[name] = importlib.import_module(name)
+    for _, name, _ in pkgutil.iter_modules():
+        if name.startswith("lynxkite_"):
+            print(f"Importing {name}")
+            plugins[name] = importlib.import_module(name)
     if not plugins:
-        print("No modules found in lynxkite_plugins. Be sure to install some plugins.")
+        print("No LynxKite plugins found. Be sure to install some!")
     return plugins
 
 
@@ -69,7 +66,7 @@ async def save_and_execute(req: SaveRequest):
 @app.post("/api/delete")
 async def delete_workspace(req: dict):
     json_path: pathlib.Path = DATA_PATH / req["path"]
-    crdt_path: pathlib.Path = CRDT_PATH / f"{req["path"]}.crdt"
+    crdt_path: pathlib.Path = CRDT_PATH / f"{req['path']}.crdt"
     assert json_path.is_relative_to(DATA_PATH)
     assert crdt_path.is_relative_to(CRDT_PATH)
     json_path.unlink()
@@ -85,8 +82,9 @@ def load(path: str):
     return workspace.load(path)
 
 
-DATA_PATH = pathlib.Path.cwd() / "data"
-CRDT_PATH = pathlib.Path.cwd() / "crdt_data"
+DATA_PATH = pathlib.Path(os.environ.get("LYNXKITE_DATA", "lynxkite_data"))
+CRDT_PATH = pathlib.Path(os.environ.get("LYNXKITE_CRDT_DATA", "lynxkite_crdt_data"))
+
 
 @dataclasses.dataclass(order=True)
 class DirectoryEntry:
@@ -120,11 +118,7 @@ def make_dir(req: dict):
 @app.post("/api/dir/delete")
 def delete_dir(req: dict):
     path: pathlib.Path = DATA_PATH / req["path"]
-    assert all([
-        path.is_relative_to(DATA_PATH),
-        path.exists(),
-        path.is_dir()
-    ])
+    assert all([path.is_relative_to(DATA_PATH), path.exists(), path.is_dir()])
     shutil.rmtree(path)
     return list_dir(path.parent)
 
@@ -159,5 +153,5 @@ class SPAStaticFiles(StaticFiles):
                 raise ex
 
 
-static_dir = SPAStaticFiles(packages=[("lynxkite.app", "web_assets")], html=True)
+static_dir = SPAStaticFiles(packages=[("lynxkite_app", "web_assets")], html=True)
 app.mount("/", static_dir, name="web_assets")

lynxkite-app/tests/test_crdt.py

@@ -1,7 +1,7 @@
 from enum import Enum
 import pycrdt
 import pytest
-from lynxkite.app.crdt import crdt_update
+from lynxkite_app.crdt import crdt_update
 
 
 @pytest.fixture

lynxkite-app/tests/test_main.py

@@ -1,6 +1,6 @@
 import uuid
 from fastapi.testclient import TestClient
-from lynxkite.app.main import app, detect_plugins, DATA_PATH
+from lynxkite_app.main import app, detect_plugins, DATA_PATH
 import os
 
 

lynxkite-app/web/src/Directory.tsx

@@ -29,8 +29,8 @@ export default function () {
   const navigate = useNavigate();
   const [isCreatingDir, setIsCreatingDir] = useState(false);
   const [isCreatingWorkspace, setIsCreatingWorkspace] = useState(false);
-  
-  
+
+
   function link(item: any) {
     if (item.type === 'directory') {
       return `/dir/${item.name}`;
@@ -38,7 +38,7 @@ export default function () {
       return `/edit/${item.name}`;
     }
   }
-  
+
   function shortName(item: any) {
     return item.name.split('/').pop();
   }
@@ -53,18 +53,18 @@ export default function () {
       i++;
     }
   }
-  
+
   function newWorkspaceIn(path: string, list: any[], workspaceName?: string) {
     const pathSlash = path ? `${path}/` : "";
     const name = workspaceName || newName(list);
-    navigate(`/edit/${pathSlash}${name}`, {replace: true});
+    navigate(`/edit/${pathSlash}${name}`, { replace: true });
   }
-  
+
 
   async function newFolderIn(path: string, list: any[], folderName?: string) {
     const name = folderName || newName(list, "New Folder");
     const pathSlash = path ? `${path}/` : "";
-  
+
     const res = await fetch(`/api/dir/mkdir`, {
       method: 'POST',
       headers: { 'Content-Type': 'application/json' },
@@ -76,12 +76,12 @@ export default function () {
       alert("Failed to create folder.");
     }
   }
-  
+
   async function deleteItem(item: any) {
     if (!window.confirm(`Are you sure you want to delete "${item.name}"?`)) return;
     const pathSlash = path ? `${path}/` : "";
 
-    const apiPath = item.type === "directory" ? `/api/dir/delete`: `/api/delete`;
+    const apiPath = item.type === "directory" ? `/api/dir/delete` : `/api/delete`;
     await fetch(apiPath, {
       method: "POST",
       headers: { "Content-Type": "application/json" },
@@ -109,39 +109,39 @@ export default function () {
         {list.data && (
           <>
             <div className="actions">
-                <div className="new-workspace">
-                  {isCreatingWorkspace && 
-                    // @ts-ignore
-                    <form onSubmit={(e) => {e.preventDefault(); newWorkspaceIn(path || "", list.data, e.target.workspaceName.value.trim())}}>
-                      <input
-                        type="text"
-                        name="workspaceName"
-                        defaultValue={newName(list.data)}
-                        placeholder={newName(list.data)}
-                      />
-                    </form>
-                  }
-                  <button type="button" onClick={() => setIsCreatingWorkspace(true)}>
-                    <FolderPlus /> New workspace
-                  </button>
-                </div>
-
-                <div className="new-folder">
-                  {isCreatingDir && 
-                    // @ts-ignore
-                    <form onSubmit={(e) =>{e.preventDefault(); newFolderIn(path || "", list.data, e.target.folderName.value.trim())}}>
-                      <input
-                        type="text"
-                        name="folderName"
-                        defaultValue={newName(list.data)}
-                        placeholder={newName(list.data)}
-                      />
-                    </form>
-                  }
-                  <button type="button" onClick={() => setIsCreatingDir(true)}>
-                    <FolderPlus /> New folder
-                  </button>
-                </div>
+              <div className="new-workspace">
+                {isCreatingWorkspace &&
+                  // @ts-ignore
+                  <form onSubmit={(e) => { e.preventDefault(); newWorkspaceIn(path || "", list.data, e.target.workspaceName.value.trim()) }}>
+                    <input
+                      type="text"
+                      name="workspaceName"
+                      defaultValue={newName(list.data)}
+                      placeholder={newName(list.data)}
+                    />
+                  </form>
+                }
+                <button type="button" onClick={() => setIsCreatingWorkspace(true)}>
+                  <FolderPlus /> New workspace
+                </button>
+              </div>
+
+              <div className="new-folder">
+                {isCreatingDir &&
+                  // @ts-ignore
+                  <form onSubmit={(e) => { e.preventDefault(); newFolderIn(path || "", list.data, e.target.folderName.value.trim()) }}>
+                    <input
+                      type="text"
+                      name="folderName"
+                      defaultValue={newName(list.data)}
+                      placeholder={newName(list.data)}
+                    />
+                  </form>
+                }
+                <button type="button" onClick={() => setIsCreatingDir(true)}>
+                  <FolderPlus /> New folder
+                </button>
+              </div>
             </div>
 
             {path && (
@@ -155,7 +155,7 @@ export default function () {
 
             {list.data.map((item: any) => (
               <div key={item.name} className="entry">
-                <a key={link(item)} className="entry" href={link(item)}>
+                <a key={link(item)} href={link(item)}>
                   {item.type === 'directory' ? <Folder /> : <File />}
                   {shortName(item)}
                 </a>

lynxkite-app/web/src/index.css

@@ -308,7 +308,6 @@ body {
   }
 
   a {
-    color: black;
     text-decoration: none;
   }
 

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

@@ -206,8 +206,10 @@ def register_executor(env: str):
 
 
 def op_registration(env: str):
+    """Returns a decorator that can be used for registering functions as operations."""
     return functools.partial(op, env)
 
 
 def passive_op_registration(env: str):
+    """Returns a function that can be used to register operations without associated code."""
     return functools.partial(register_passive_op, env)

lynxkite-graph-analytics/pyproject.toml

@@ -17,8 +17,8 @@ dependencies = [
 
 [project.optional-dependencies]
 dev = [
-    "pytest",
-    "pytest-asyncio",
+    "pytest>=8.3.4",
+    "pytest-asyncio>=0.25.3",
 ]
 gpu = [
     "nx-cugraph-cu12>=24.12.0",
@@ -28,4 +28,4 @@ gpu = [
 lynxkite-core = { path = "../lynxkite-core" }
 
 [tool.pytest.ini_options]
-asyncio_mode = "auto"
+asyncio_mode = "auto"

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

@@ -0,0 +1,3 @@
+from . import lynxkite_ops  # noqa (imported to trigger registration)
+from . import networkx_ops  # noqa (imported to trigger registration)
+from . import pytorch_model_ops  # noqa (imported to trigger registration)

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

@@ -1,3 +0,0 @@
-from . import lynxkite_ops
-from . import networkx_ops
-from . import pytorch_model_ops

lynxkite-graph-analytics/tests/test_lynxkite_ops.py

@@ -3,7 +3,7 @@ import pytest
 import networkx as nx
 
 from lynxkite.core import workspace
-from lynxkite_plugins.graph_analytics.lynxkite_ops import Bundle, execute, op
+from lynxkite_graph_analytics.lynxkite_ops import Bundle, execute, op
 
 
 async def test_execute_operation_not_in_catalog():

lynxkite-lynxscribe/README.md

@@ -5,7 +5,7 @@ LynxKite UI for building LynxScribe chat applications. Also runs the chat applic
 To run a chat UI for LynxScribe workspaces:
 
 ```bash
-WEBUI_AUTH=false OPENAI_API_BASE_URL=http://localhost:8000/api/service/server.lynxscribe_ops uvx open-webui serve
+WEBUI_AUTH=false OPENAI_API_BASE_URL=http://localhost:8000/api/service/lynxscribe/lynxscribe_ops uvx open-webui serve
 ```
 
 Or use [Lynx WebUI](https://github.com/biggraph/lynx-webui/) instead of Open WebUI.

lynxkite-lynxscribe/src/{lynxkite_plugins/lynxscribe → lynxkite_lynxscribe}/__init__.py

@@ -1,5 +1,5 @@
-from . import lynxscribe_ops
-from . import llm_ops
+from . import lynxscribe_ops  # noqa (imported to trigger registration)
+from . import llm_ops  # noqa (imported to trigger registration)
 from .lynxscribe_ops import api_service_post, api_service_get
 
 __all__ = ["api_service_post", "api_service_get"]

lynxkite-pillow-example/pyproject.toml

@@ -8,8 +8,8 @@ dependencies = [
     "fsspec>=2025.2.0",
     "lynxkite-core",
     "pillow>=11.1.0",
-    "requests",
-    "aiohttp",
+    "requests>=2.32.3",
+    "aiohttp>=3.11.11",
 ]
 
 [tool.uv.sources]