Update LynxScribe module with recent changes.

lynxkite-core/src/lynxkite/core/executors/one_by_one.py

@@ -142,12 +142,12 @@ async def execute(ws: workspace.Workspace, catalog, cache=None):
                         key = make_cache_key((inputs, params))
                         if key not in cache:
                             result: ops.Result = op(*inputs, **params)
-                            output = await await_if_needed(result.output)
-                            cache[key] = output
-                        output = cache[key]
+                            result.output = await await_if_needed(result.output)
+                            cache[key] = result
+                        result = cache[key]
                     else:
                         result = op(*inputs, **params)
-                        output = await await_if_needed(result.output)
+                    output = await await_if_needed(result.output)
                 except Exception as e:
                     traceback.print_exc()
                     node.publish_error(e)

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/lynxscribe/lynxscribe_ops uvx open-webui serve
+WEBUI_AUTH=false OPENAI_API_BASE_URL=http://localhost:8000/api/service/lynxkite_lynxscribe uvx open-webui serve
 ```
 
 Or use [Lynx WebUI](https://github.com/biggraph/lynx-webui/) instead of Open WebUI.

lynxkite-lynxscribe/src/lynxkite_lynxscribe/lynxscribe_ops.py

@@ -2,6 +2,8 @@
 LynxScribe configuration and testing in LynxKite.
 """
 
+import os
+import pathlib
 from lynxscribe.core.llm.base import get_llm_engine
 from lynxscribe.core.vector_store.base import get_vector_store
 from lynxscribe.common.config import load_config
@@ -221,10 +223,8 @@ def view(input):
 
 
 async def get_chat_api(ws):
-    import pathlib
     from lynxkite.core import workspace
 
-    DATA_PATH = pathlib.Path.cwd() / "data"
     path = DATA_PATH / ws
     assert path.is_relative_to(DATA_PATH)
     assert path.exists(), f"Workspace {path} does not exist"
@@ -285,18 +285,19 @@ async def api_service_get(request):
     return {"error": "Not found"}
 
 
+DATA_PATH = pathlib.Path(os.environ.get("LYNXKITE_DATA", "lynxkite_data"))
+
+
 def get_lynxscribe_workspaces():
-    import pathlib
     from lynxkite.core import workspace
 
-    DATA_DIR = pathlib.Path.cwd() / "data"
     workspaces = []
-    for p in DATA_DIR.glob("**/*"):
+    for p in DATA_PATH.glob("**/*"):
         if p.is_file():
             try:
                 ws = workspace.load(p)
                 if ws.env == ENV:
-                    workspaces.append(p.relative_to(DATA_DIR))
+                    workspaces.append(p.relative_to(DATA_PATH))
             except Exception:
                 pass  # Ignore files that are not valid workspaces.
     workspaces.sort()