fix(client,graph,demo): preserve language in TextIndexInfo fallback; backfill schema text; add Dockerfile.jupyter

- client.py: fallback TextIndexInfo (empty CREATE TEXT INDEX rows) now
  includes default_language so callers always get the explicit language back
- client.py: fix isinstance tuple → union type (ruff UP038)
- graph.py: add _structured_to_text(); backfill self._schema when only
  get_labels()/get_edge_types() are available, keeping graph.schema
  consistent with graph.structured_schema
- demo/Dockerfile.jupyter: add missing file referenced by docker-compose.yml
- demo/notebooks: extract ACME_CORP constant (03); fix rustup flags (00)

Author: polaz

coordinode/coordinode/client.py

@@ -471,7 +471,7 @@ def _build_property_definitions(
         }
         if properties is None:
             return []
-        if not isinstance(properties, (list, tuple)):
+        if not isinstance(properties, list | tuple):
             raise ValueError(f"'properties' must be a list of property dicts or None; got {type(properties).__name__}")
         result = []
         for idx, p in enumerate(properties):
@@ -613,7 +613,9 @@ async def create_text_index(
         rows = await self.cypher(cypher)
         if rows:
             return TextIndexInfo(rows[0])
-        return TextIndexInfo({"index": name, "label": label, "properties": ", ".join(prop_list)})
+        return TextIndexInfo(
+            {"index": name, "label": label, "properties": ", ".join(prop_list), "default_language": language}
+        )
 
     async def drop_text_index(self, name: str) -> None:
         """Drop a full-text index by name.

demo/Dockerfile.jupyter

@@ -0,0 +1,32 @@
+FROM jupyter/scipy-notebook:latest
+
+USER root
+RUN apt-get update && apt-get install -y --no-install-recommends gcc git && rm -rf /var/lib/apt/lists/*
+
+# Copy and chmod install script while still root
+COPY install-sdk.sh /tmp/install-sdk.sh
+RUN chmod +x /tmp/install-sdk.sh
+
+USER ${NB_UID}
+
+# Core graph + LLM orchestration stack
+RUN pip install --no-cache-dir \
+    # build tools for SDK editable installs (hatch-vcs reads git tags for versioning)
+    hatchling \
+    hatch-vcs \
+    nest_asyncio \
+    # LlamaIndex core + graph store protocol
+    llama-index-core \
+    llama-index-llms-openai \
+    llama-index-embeddings-openai \
+    # LangChain + LangGraph
+    langchain \
+    langchain-openai \
+    langchain-community \
+    langgraph \
+    # coordinode SDK packages (installed from mounted /sdk)
+    grpcio \
+    grpcio-tools \
+    protobuf
+
+WORKDIR /home/jovyan/work

demo/notebooks/00_seed_data.ipynb

@@ -50,7 +50,77 @@
    "id": "a1b2c3d4-0000-0000-0000-000000000003",
    "metadata": {},
    "outputs": [],
-   "source": "import os, sys, subprocess\n\nIN_COLAB = \"google.colab\" in sys.modules\n\n# Install coordinode-embedded only when running in Colab AND no gRPC server is configured.\n# If COORDINODE_ADDR is set, a live server is already available — skip the 5-min Rust build.\nif IN_COLAB and not os.environ.get(\"COORDINODE_ADDR\"):\n    # Install Rust toolchain via rustup (https://rustup.rs).\n    # Colab's apt packages ship rustc ≤1.75, which cannot build coordinode-embedded\n    # (requires Rust ≥1.80 for maturin/pyo3). apt-get is not a viable alternative here.\n    # Download the installer to a temp file and execute it explicitly — this avoids\n    # piping remote content directly into a shell while maintaining HTTPS/TLS security\n    # through Python's default ssl context (cert-verified, TLS 1.2+).\n    # SHA256 pinning of rustup-init is intentionally omitted: rustup.rs does not\n    # publish a stable per-release checksum for sh.rustup.rs itself (only for\n    # platform-specific rustup-init binaries), and pinning a hash here would break\n    # silently on every rustup release. The HTTPS/TLS verification + temp-file\n    # execution (not piped to shell) is the rustup team's recommended trust model.\n    # No additional env-var gate (e.g. COORDINODE_ENABLE_RUSTUP) is needed:\n    # the `IN_COLAB and not COORDINODE_ADDR` check above already ensures this block\n    # never runs when a live gRPC server is available, so there is no risk of\n    # unintentional execution in local or server environments.\n    import ssl as _ssl, tempfile as _tmp, urllib.request as _ur\n\n    _ctx = _ssl.create_default_context()\n    with _tmp.NamedTemporaryFile(mode=\"wb\", suffix=\".sh\", delete=False) as _f:\n        with _ur.urlopen(\"https://sh.rustup.rs\", context=_ctx, timeout=30) as _r:\n            _f.write(_r.read())\n        _rustup_path = _f.name\n    try:\n        subprocess.run([\"/bin/sh\", _rustup_path, \"-s\", \"--\", \"-y\", \"-q\"], check=True, timeout=300)\n    finally:\n        os.unlink(_rustup_path)\n    # Add cargo to PATH so maturin/pip can find it.\n    _cargo_bin = os.path.expanduser(\"~/.cargo/bin\")\n    os.environ[\"PATH\"] = f\"{_cargo_bin}{os.pathsep}{os.environ.get('PATH', '')}\"\n    subprocess.run([sys.executable, \"-m\", \"pip\", \"install\", \"-q\", \"maturin\"], check=True, timeout=300)\n    subprocess.run(\n        [\n            sys.executable,\n            \"-m\",\n            \"pip\",\n            \"install\",\n            \"-q\",\n            \"git+https://github.com/structured-world/coordinode-python.git@4efc7b287211f4cfcf203ce92c83773d7d72ff61#subdirectory=coordinode-embedded\",\n        ],\n        check=True,\n        timeout=600,\n    )\n\nsubprocess.run(\n    [\n        sys.executable,\n        \"-m\",\n        \"pip\",\n        \"install\",\n        \"-q\",\n        \"coordinode\",\n        \"nest_asyncio\",\n    ],\n    check=True,\n    timeout=300,\n)\n\nimport nest_asyncio\n\nnest_asyncio.apply()\n\nprint(\"Ready\")"
+   "source": [
+    "import os, sys, subprocess\n",
+    "\n",
+    "IN_COLAB = \"google.colab\" in sys.modules\n",
+    "\n",
+    "# Install coordinode-embedded only when running in Colab AND no gRPC server is configured.\n",
+    "# If COORDINODE_ADDR is set, a live server is already available — skip the 5-min Rust build.\n",
+    "if IN_COLAB and not os.environ.get(\"COORDINODE_ADDR\"):\n",
+    "    # Install Rust toolchain via rustup (https://rustup.rs).\n",
+    "    # Colab's apt packages ship rustc ≤1.75, which cannot build coordinode-embedded\n",
+    "    # (requires Rust ≥1.80 for maturin/pyo3). apt-get is not a viable alternative here.\n",
+    "    # Download the installer to a temp file and execute it explicitly — this avoids\n",
+    "    # piping remote content directly into a shell while maintaining HTTPS/TLS security\n",
+    "    # through Python's default ssl context (cert-verified, TLS 1.2+).\n",
+    "    # SHA256 pinning of rustup-init is intentionally omitted: rustup.rs does not\n",
+    "    # publish a stable per-release checksum for sh.rustup.rs itself (only for\n",
+    "    # platform-specific rustup-init binaries), and pinning a hash here would break\n",
+    "    # silently on every rustup release. The HTTPS/TLS verification + temp-file\n",
+    "    # execution (not piped to shell) is the rustup team's recommended trust model.\n",
+    "    # No additional env-var gate (e.g. COORDINODE_ENABLE_RUSTUP) is needed:\n",
+    "    # the `IN_COLAB and not COORDINODE_ADDR` check above already ensures this block\n",
+    "    # never runs when a live gRPC server is available, so there is no risk of\n",
+    "    # unintentional execution in local or server environments.\n",
+    "    import ssl as _ssl, tempfile as _tmp, urllib.request as _ur\n",
+    "\n",
+    "    _ctx = _ssl.create_default_context()\n",
+    "    with _tmp.NamedTemporaryFile(mode=\"wb\", suffix=\".sh\", delete=False) as _f:\n",
+    "        with _ur.urlopen(\"https://sh.rustup.rs\", context=_ctx, timeout=30) as _r:\n",
+    "            _f.write(_r.read())\n",
+    "        _rustup_path = _f.name\n",
+    "    try:\n",
+    "        subprocess.run([\"/bin/sh\", _rustup_path, \"-y\", \"-q\"], check=True, timeout=300)\n",
+    "    finally:\n",
+    "        os.unlink(_rustup_path)\n",
+    "    # Add cargo to PATH so maturin/pip can find it.\n",
+    "    _cargo_bin = os.path.expanduser(\"~/.cargo/bin\")\n",
+    "    os.environ[\"PATH\"] = f\"{_cargo_bin}{os.pathsep}{os.environ.get('PATH', '')}\"\n",
+    "    subprocess.run([sys.executable, \"-m\", \"pip\", \"install\", \"-q\", \"maturin\"], check=True, timeout=300)\n",
+    "    subprocess.run(\n",
+    "        [\n",
+    "            sys.executable,\n",
+    "            \"-m\",\n",
+    "            \"pip\",\n",
+    "            \"install\",\n",
+    "            \"-q\",\n",
+    "            \"git+https://github.com/structured-world/coordinode-python.git@4efc7b287211f4cfcf203ce92c83773d7d72ff61#subdirectory=coordinode-embedded\",\n",
+    "        ],\n",
+    "        check=True,\n",
+    "        timeout=600,\n",
+    "    )\n",
+    "\n",
+    "subprocess.run(\n",
+    "    [\n",
+    "        sys.executable,\n",
+    "        \"-m\",\n",
+    "        \"pip\",\n",
+    "        \"install\",\n",
+    "        \"-q\",\n",
+    "        \"coordinode\",\n",
+    "        \"nest_asyncio\",\n",
+    "    ],\n",
+    "    check=True,\n",
+    "    timeout=300,\n",
+    ")\n",
+    "\n",
+    "import nest_asyncio\n",
+    "\n",
+    "nest_asyncio.apply()\n",
+    "\n",
+    "print(\"Ready\")"
+   ]
   },
   {
    "cell_type": "markdown",

demo/notebooks/03_langgraph_agent.ipynb

@@ -315,11 +315,13 @@
    "metadata": {},
    "outputs": [],
    "source": [
+    "ACME_CORP = \"Acme Corp\"  # constant used in several save_fact calls below\n",
+    "\n",
     "print(\"=== Saving facts ===\")\n",
-    "print(save_fact.invoke({\"subject\": \"Alice\", \"relation\": \"WORKS_AT\", \"obj\": \"Acme Corp\"}))\n",
+    "print(save_fact.invoke({\"subject\": \"Alice\", \"relation\": \"WORKS_AT\", \"obj\": ACME_CORP}))\n",
     "print(save_fact.invoke({\"subject\": \"Alice\", \"relation\": \"MANAGES\", \"obj\": \"Bob\"}))\n",
-    "print(save_fact.invoke({\"subject\": \"Bob\", \"relation\": \"WORKS_AT\", \"obj\": \"Acme Corp\"}))\n",
-    "print(save_fact.invoke({\"subject\": \"Acme Corp\", \"relation\": \"LOCATED_IN\", \"obj\": \"Berlin\"}))\n",
+    "print(save_fact.invoke({\"subject\": \"Bob\", \"relation\": \"WORKS_AT\", \"obj\": ACME_CORP}))\n",
+    "print(save_fact.invoke({\"subject\": ACME_CORP, \"relation\": \"LOCATED_IN\", \"obj\": \"Berlin\"}))\n",
     "print(save_fact.invoke({\"subject\": \"Alice\", \"relation\": \"KNOWS\", \"obj\": \"Charlie\"}))\n",
     "print(save_fact.invoke({\"subject\": \"Charlie\", \"relation\": \"EXPERT_IN\", \"obj\": \"Machine Learning\"}))\n",
     "\n",
@@ -336,10 +338,10 @@
     "print(\n",
     "    query_facts.invoke(\n",
     "        {\n",
-    "            \"cypher\": 'MATCH (p:Entity {session: $sess})-[:WORKS_AT]->(c:Entity {name: \"Acme Corp\", session: $sess}) RETURN p.name AS employee'\n",
+    "            \"cypher\": f'MATCH (p:Entity {{session: $sess}})-[:WORKS_AT]->(c:Entity {{name: \"{ACME_CORP}\", session: $sess}}) RETURN p.name AS employee'\n",
     "        }\n",
     "    )\n",
-    ")"
+    ")\n"
    ]
   },
   {

langchain-coordinode/langchain_coordinode/graph.py

@@ -126,6 +126,11 @@ def refresh_schema(self) -> None:
                     ]
                 if node_props or rel_props:
                     structured: dict[str, Any] = {"node_props": node_props, "rel_props": rel_props, "relationships": []}
+                    # Backfill text schema for clients that expose get_labels()/get_edge_types()
+                    # but not get_schema_text().  Keeps graph.schema consistent with
+                    # graph.structured_schema so callers that read either view get the same data.
+                    if not self._schema:
+                        self._schema = _structured_to_text(node_props, rel_props)
                 else:
                     # Both APIs returned empty (e.g. schema-free graph or stub adapter) —
                     # fall back to text parsing so we don't lose what get_schema_text() returned.
@@ -392,6 +397,34 @@ def _cypher_ident(name: str) -> str:
     return f"`{name.replace('`', '``')}`"
 
 
+def _structured_to_text(
+    node_props: dict[str, list[dict[str, str]]],
+    rel_props: dict[str, list[dict[str, str]]],
+) -> str:
+    """Render node_props/rel_props dicts as a schema text string.
+
+    Produces the same format that :func:`_parse_schema` consumes, so the two
+    functions are inverses.  Used to backfill ``self._schema`` when the server
+    exposes ``get_labels()`` / ``get_edge_types()`` but not ``get_schema_text()``.
+    """
+    lines: list[str] = ["Node labels:"]
+    for label, props in sorted(node_props.items()):
+        if props:
+            props_str = ", ".join(f"{p['property']}: {p['type']}" for p in props)
+            lines.append(f"  - {label} (properties: {props_str})")
+        else:
+            lines.append(f"  - {label}")
+    lines.append("")
+    lines.append("Edge types:")
+    for rel_type, props in sorted(rel_props.items()):
+        if props:
+            props_str = ", ".join(f"{p['property']}: {p['type']}" for p in props)
+            lines.append(f"  - {rel_type} (properties: {props_str})")
+        else:
+            lines.append(f"  - {rel_type}")
+    return "\n".join(lines)
+
+
 def _parse_schema(schema_text: str) -> dict[str, Any]:
     """Convert CoordiNode schema text into LangChain's structured format.