Following the schema change, Value -> Term

This commit is contained in:
Cyber MacGeddon 2026-01-26 23:01:54 +00:00
parent 16e66d0150
commit 7c1c52b39f
10 changed files with 18 additions and 18 deletions

View file

@ -7,7 +7,7 @@ embeddings.
import logging import logging
from .. schema import DocumentEmbeddingsRequest, DocumentEmbeddingsResponse from .. schema import DocumentEmbeddingsRequest, DocumentEmbeddingsResponse
from .. schema import Error, Value from .. schema import Error, Term
from . flow_processor import FlowProcessor from . flow_processor import FlowProcessor
from . consumer_spec import ConsumerSpec from . consumer_spec import ConsumerSpec

View file

@ -7,7 +7,7 @@ embeddings.
import logging import logging
from .. schema import GraphEmbeddingsRequest, GraphEmbeddingsResponse from .. schema import GraphEmbeddingsRequest, GraphEmbeddingsResponse
from .. schema import Error, Value from .. schema import Error, Term
from . flow_processor import FlowProcessor from . flow_processor import FlowProcessor
from . consumer_spec import ConsumerSpec from . consumer_spec import ConsumerSpec

View file

@ -7,7 +7,7 @@ null. Output is a list of triples.
import logging import logging
from .. schema import TriplesQueryRequest, TriplesQueryResponse, Error from .. schema import TriplesQueryRequest, TriplesQueryResponse, Error
from .. schema import Value, Triple from .. schema import Term, Triple
from . flow_processor import FlowProcessor from . flow_processor import FlowProcessor
from . consumer_spec import ConsumerSpec from . consumer_spec import ConsumerSpec

View file

@ -2,7 +2,7 @@
import _pulsar import _pulsar
from .. schema import TriplesQueryRequest, TriplesQueryResponse, Value from .. schema import TriplesQueryRequest, TriplesQueryResponse, Term, IRI, LITERAL
from .. schema import triples_request_queue from .. schema import triples_request_queue
from .. schema import triples_response_queue from .. schema import triples_response_queue
from . base import BaseClient from . base import BaseClient
@ -46,9 +46,9 @@ class TriplesQueryClient(BaseClient):
if ent == None: return None if ent == None: return None
if ent.startswith("http://") or ent.startswith("https://"): if ent.startswith("http://") or ent.startswith("https://"):
return Value(value=ent, is_uri=True) return Term(type=IRI, iri=ent)
return Value(value=ent, is_uri=False) return Term(type=LITERAL, value=ent)
def request( def request(
self, self,

View file

@ -1,5 +1,5 @@
from .base import Translator, MessageTranslator from .base import Translator, MessageTranslator
from .primitives import ValueTranslator, TripleTranslator, SubgraphTranslator, RowSchemaTranslator, FieldTranslator, row_schema_translator, field_translator from .primitives import TermTranslator, ValueTranslator, TripleTranslator, SubgraphTranslator, RowSchemaTranslator, FieldTranslator, row_schema_translator, field_translator
from .metadata import DocumentMetadataTranslator, ProcessingMetadataTranslator from .metadata import DocumentMetadataTranslator, ProcessingMetadataTranslator
from .agent import AgentRequestTranslator, AgentResponseTranslator from .agent import AgentRequestTranslator, AgentResponseTranslator
from .embeddings import EmbeddingsRequestTranslator, EmbeddingsResponseTranslator from .embeddings import EmbeddingsRequestTranslator, EmbeddingsResponseTranslator

View file

@ -1,7 +1,7 @@
from dataclasses import dataclass, field from dataclasses import dataclass, field
from ..core.metadata import Metadata from ..core.metadata import Metadata
from ..core.primitives import Value, RowSchema from ..core.primitives import Term, RowSchema
from ..core.topic import topic from ..core.topic import topic
############################################################################ ############################################################################
@ -10,7 +10,7 @@ from ..core.topic import topic
@dataclass @dataclass
class EntityEmbeddings: class EntityEmbeddings:
entity: Value | None = None entity: Term | None = None
vectors: list[list[float]] = field(default_factory=list) vectors: list[list[float]] = field(default_factory=list)
# This is a 'batching' mechanism for the above data # This is a 'batching' mechanism for the above data

View file

@ -1,6 +1,6 @@
from dataclasses import dataclass, field from dataclasses import dataclass, field
from ..core.primitives import Value, Triple from ..core.primitives import Term, Triple
from ..core.metadata import Metadata from ..core.metadata import Metadata
from ..core.topic import topic from ..core.topic import topic
@ -10,7 +10,7 @@ from ..core.topic import topic
@dataclass @dataclass
class EntityContext: class EntityContext:
entity: Value | None = None entity: Term | None = None
context: str = "" context: str = ""
# This is a 'batching' mechanism for the above data # This is a 'batching' mechanism for the above data

View file

@ -1,6 +1,6 @@
from dataclasses import dataclass from dataclasses import dataclass
from ..core.primitives import Error, Value, Triple from ..core.primitives import Error, Term, Triple
from ..core.topic import topic from ..core.topic import topic
from ..core.metadata import Metadata from ..core.metadata import Metadata

View file

@ -1,6 +1,6 @@
from dataclasses import dataclass, field from dataclasses import dataclass, field
from ..core.primitives import Error, Value, Triple from ..core.primitives import Error, Term, Triple
from ..core.topic import topic from ..core.topic import topic
############################################################################ ############################################################################
@ -17,7 +17,7 @@ class GraphEmbeddingsRequest:
@dataclass @dataclass
class GraphEmbeddingsResponse: class GraphEmbeddingsResponse:
error: Error | None = None error: Error | None = None
entities: list[Value] = field(default_factory=list) entities: list[Term] = field(default_factory=list)
############################################################################ ############################################################################
@ -27,9 +27,9 @@ class GraphEmbeddingsResponse:
class TriplesQueryRequest: class TriplesQueryRequest:
user: str = "" user: str = ""
collection: str = "" collection: str = ""
s: Value | None = None s: Term | None = None
p: Value | None = None p: Term | None = None
o: Value | None = None o: Term | None = None
limit: int = 0 limit: int = 0
@dataclass @dataclass

View file

@ -1,6 +1,6 @@
from dataclasses import dataclass from dataclasses import dataclass
from ..core.topic import topic from ..core.topic import topic
from ..core.primitives import Error, Value from ..core.primitives import Error, Term
############################################################################ ############################################################################