From 30699edf08ec2f3b0b4b09d8fe989b63d088e89f Mon Sep 17 00:00:00 2001
From: Cyber MacGeddon <cybermaggedon@gmail.com>
Date: Mon, 26 Jan 2026 23:14:45 +0000
Subject: [PATCH] Following the schema change, Value -> Term in the vector
 stores

---
 .../trustgraph/query/doc_embeddings/milvus/service.py       | 2 +-
 .../trustgraph/query/doc_embeddings/qdrant/service.py       | 2 +-
 .../trustgraph/query/graph_embeddings/milvus/service.py     | 6 +++---
 .../trustgraph/query/graph_embeddings/pinecone/service.py   | 6 +++---
 .../trustgraph/query/graph_embeddings/qdrant/service.py     | 6 +++---
 5 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/trustgraph-flow/trustgraph/query/doc_embeddings/milvus/service.py b/trustgraph-flow/trustgraph/query/doc_embeddings/milvus/service.py
index 2915184c..7f269329 100755
--- a/trustgraph-flow/trustgraph/query/doc_embeddings/milvus/service.py
+++ b/trustgraph-flow/trustgraph/query/doc_embeddings/milvus/service.py
@@ -8,7 +8,7 @@ import logging
 
 from .... direct.milvus_doc_embeddings import DocVectors
 from .... schema import DocumentEmbeddingsResponse
-from .... schema import Error, Value
+from .... schema import Error
 from .... base import DocumentEmbeddingsQueryService
 
 # Module logger
diff --git a/trustgraph-flow/trustgraph/query/doc_embeddings/qdrant/service.py b/trustgraph-flow/trustgraph/query/doc_embeddings/qdrant/service.py
index 46e9e687..16f77ad5 100755
--- a/trustgraph-flow/trustgraph/query/doc_embeddings/qdrant/service.py
+++ b/trustgraph-flow/trustgraph/query/doc_embeddings/qdrant/service.py
@@ -11,7 +11,7 @@ from qdrant_client.models import PointStruct
 from qdrant_client.models import Distance, VectorParams
 
 from .... schema import DocumentEmbeddingsResponse
-from .... schema import Error, Value
+from .... schema import Error
 from .... base import DocumentEmbeddingsQueryService
 
 # Module logger
diff --git a/trustgraph-flow/trustgraph/query/graph_embeddings/milvus/service.py b/trustgraph-flow/trustgraph/query/graph_embeddings/milvus/service.py
index cb9255c2..3ee34ba7 100755
--- a/trustgraph-flow/trustgraph/query/graph_embeddings/milvus/service.py
+++ b/trustgraph-flow/trustgraph/query/graph_embeddings/milvus/service.py
@@ -8,7 +8,7 @@ import logging
 
 from .... direct.milvus_graph_embeddings import EntityVectors
 from .... schema import GraphEmbeddingsResponse
-from .... schema import Error, Value
+from .... schema import Error, Term, IRI, LITERAL
 from .... base import GraphEmbeddingsQueryService
 
 # Module logger
@@ -33,9 +33,9 @@ class Processor(GraphEmbeddingsQueryService):
 
     def create_value(self, ent):
         if ent.startswith("http://") or ent.startswith("https://"):
-            return Value(value=ent, is_uri=True)
+            return Term(type=IRI, iri=ent)
         else:
-            return Value(value=ent, is_uri=False)
+            return Term(type=LITERAL, value=ent)
         
     async def query_graph_embeddings(self, msg):
 
diff --git a/trustgraph-flow/trustgraph/query/graph_embeddings/pinecone/service.py b/trustgraph-flow/trustgraph/query/graph_embeddings/pinecone/service.py
index f6277e4f..c90f64dd 100755
--- a/trustgraph-flow/trustgraph/query/graph_embeddings/pinecone/service.py
+++ b/trustgraph-flow/trustgraph/query/graph_embeddings/pinecone/service.py
@@ -12,7 +12,7 @@ from pinecone import Pinecone, ServerlessSpec
 from pinecone.grpc import PineconeGRPC, GRPCClientConfig
 
 from .... schema import GraphEmbeddingsResponse
-from .... schema import Error, Value
+from .... schema import Error, Term, IRI, LITERAL
 from .... base import GraphEmbeddingsQueryService
 
 # Module logger
@@ -51,9 +51,9 @@ class Processor(GraphEmbeddingsQueryService):
 
     def create_value(self, ent):
         if ent.startswith("http://") or ent.startswith("https://"):
-            return Value(value=ent, is_uri=True)
+            return Term(type=IRI, iri=ent)
         else:
-            return Value(value=ent, is_uri=False)
+            return Term(type=LITERAL, value=ent)
         
     async def query_graph_embeddings(self, msg):
 
diff --git a/trustgraph-flow/trustgraph/query/graph_embeddings/qdrant/service.py b/trustgraph-flow/trustgraph/query/graph_embeddings/qdrant/service.py
index 513fd2e4..bf11e1c9 100755
--- a/trustgraph-flow/trustgraph/query/graph_embeddings/qdrant/service.py
+++ b/trustgraph-flow/trustgraph/query/graph_embeddings/qdrant/service.py
@@ -11,7 +11,7 @@ from qdrant_client.models import PointStruct
 from qdrant_client.models import Distance, VectorParams
 
 from .... schema import GraphEmbeddingsResponse
-from .... schema import Error, Value
+from .... schema import Error, Term, IRI, LITERAL
 from .... base import GraphEmbeddingsQueryService
 
 # Module logger
@@ -67,9 +67,9 @@ class Processor(GraphEmbeddingsQueryService):
 
     def create_value(self, ent):
         if ent.startswith("http://") or ent.startswith("https://"):
-            return Value(value=ent, is_uri=True)
+            return Term(type=IRI, iri=ent)
         else:
-            return Value(value=ent, is_uri=False)
+            return Term(type=LITERAL, value=ent)
         
     async def query_graph_embeddings(self, msg):