fix(adapters): fix wildcard [r] in refresh_schema, depth default, docstrings

- refresh_schema: build typed [r:T1|T2|...] pattern from rel_props keys
  (CoordiNode wildcard [r] returns no results)
- get_rel_map: change default depth from 2 to 1 (depth != 1 now raises)
- _stable_document_id docstring: clarify only __Document__ node ID is
  stable; MENTIONS edges are not deduplicated (unconditional CREATE)
- upsert_relations: add comment explaining WHERE NOT (pattern) returns 0
  rows silently in CoordiNode, hence unconditional CREATE is used

Author: polaz

langchain-coordinode/langchain_coordinode/graph.py

@@ -71,17 +71,23 @@ def refresh_schema(self) -> None:
         structured = _parse_schema(text)
         # Augment with relationship triples (start_label, type, end_label) via
         # Cypher — get_schema_text() only lists edge types without direction.
-        try:
-            rows = self._client.cypher(
-                "MATCH (a)-[r]->(b) RETURN DISTINCT a.__label__ AS src, r.__type__ AS rel, b.__label__ AS dst"
-            )
-            structured["relationships"] = [
-                {"start": row["src"], "type": row["rel"], "end": row["dst"]}
-                for row in rows
-                if row.get("src") and row.get("rel") and row.get("dst")
-            ]
-        except Exception:  # noqa: BLE001
-            pass  # Graph may have no relationships yet; structured["relationships"] stays []
+        # CoordiNode: wildcard [r] returns no results; build typed pattern from
+        # the rel_props keys returned by _parse_schema().
+        rel_types = list(structured.get("rel_props", {}).keys())
+        if rel_types:
+            try:
+                rel_filter = "|".join(_cypher_ident(t) for t in rel_types)
+                rows = self._client.cypher(
+                    f"MATCH (a)-[r:{rel_filter}]->(b) "
+                    "RETURN DISTINCT a.__label__ AS src, r.__type__ AS rel, b.__label__ AS dst"
+                )
+                structured["relationships"] = [
+                    {"start": row["src"], "type": row["rel"], "end": row["dst"]}
+                    for row in rows
+                    if row.get("src") and row.get("rel") and row.get("dst")
+                ]
+            except Exception:  # noqa: BLE001
+                pass  # Graph may have no relationships yet; structured["relationships"] stays []
         self._structured_schema = structured
 
     def add_graph_documents(
@@ -199,8 +205,11 @@ def _stable_document_id(source: Any) -> str:
     """Return a deterministic ID for a LangChain Document.
 
     Combines ``page_content`` and sorted ``metadata`` items so the same
-    document produces the same node across different Python processes,
-    making ``include_source=True`` re-ingest truly idempotent.
+    document produces the same ``__Document__`` node ID across different
+    Python processes.  This makes document-node creation stable when
+    ``include_source=True`` is used, but does not make re-ingest fully
+    idempotent because ``MENTIONS`` edges are not deduplicated until edge
+    ``MERGE``/dedup support is added to CoordiNode.
     """
     content = getattr(source, "page_content", "") or ""
     metadata = getattr(source, "metadata", {}) or {}

llama-index-coordinode/llama_index/graph_stores/coordinode/base.py

@@ -164,7 +164,7 @@ def get_triplets(
     def get_rel_map(
         self,
         graph_nodes: list[LabelledNode],
-        depth: int = 2,
+        depth: int = 1,
         limit: int = 30,
         ignore_rels: list[str] | None = None,
     ) -> list[list[LabelledNode]]:
@@ -235,10 +235,12 @@ def upsert_relations(self, relations: list[Relation]) -> None:
             props = rel.properties or {}
             label = _cypher_ident(rel.label)
             # CoordiNode does not yet support MERGE for edge patterns; use CREATE.
+            # A WHERE NOT (src)-[:TYPE]->(dst) guard was tested but returns 0
+            # rows silently in CoordiNode, making all CREATE statements no-ops.
+            # Until server-side MERGE or pattern predicates are supported,
+            # repeated calls will create duplicate edges.
             # SET r += $props is skipped when props is empty — SET r += {} is
             # not supported by all server versions.
-            # Note: repeated calls will create duplicate edges until MERGE for
-            # edges is implemented server-side.
             if props:
                 cypher = (
                     f"MATCH (src {{id: $src_id}}) MATCH (dst {{id: $dst_id}}) "