apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-21 11:11:03 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Fix some typos

Browse source
This commit is contained in:
Cyber MacGeddon 2025-04-20 09:15:12 +01:00
parent 9ec76a0bd1
commit 793f986b06
5 changed files with 11 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

3
trustgraph-base/trustgraph/base/consumer.py
View file

@ -83,7 +83,8 @@ class Consumer:
topic = self.topic,
subscription_name = self.subscriber,
schema = JsonSchema(self.schema),
initial_position = pos
initial_position = pos,
consumer_type = pulsar.ConsumerType.Shared,
)
except Exception as e:

2
trustgraph-base/trustgraph/base/consumer_spec.py
View file

@ -20,7 +20,7 @@ class ConsumerSpec(Spec):
flow = flow,
client = processor.client,
topic = definition[self.name],
subscriber = flow.id,
subscriber = flow.id + "---" + self.name,
schema = self.schema,
handler = self.handler,
metrics = consumer_metrics,

3
trustgraph-flow/trustgraph/storage/doc_embeddings/qdrant/write.py
View file

@ -43,7 +43,8 @@ class Processor(DocumentEmbeddingsStoreService):
dim = len(vec)
collection = (
"d_" + message.metadata.user + "_" + message.metadata.collection + "_" +
"d_" + message.metadata.user + "_" +
message.metadata.collection + "_" +
str(dim)
)

2
trustgraph-flow/trustgraph/storage/graph_embeddings/qdrant/write.py
View file

@ -68,7 +68,7 @@ class Processor(GraphEmbeddingsStoreService):
dim = len(vec)
collection = self.get_collection(
dim, v.metadata.user, v.metadata.collection
dim, message.metadata.user, message.metadata.collection
)
self.qdrant.upsert(

8
trustgraph-flow/trustgraph/storage/triples/cassandra/write.py
View file

@ -50,13 +50,15 @@ class Processor(TriplesStoreService):
if self.username and self.password:
self.tg = TrustGraph(
hosts=self.graph_host,
keyspace=v.metadata.user, table=v.metadata.collection,
keyspace=message.metadata.user,
table=message.metadata.collection,
username=self.username, password=self.password
)
else:
self.tg = TrustGraph(
hosts=self.graph_host,
keyspace=v.metadata.user, table=v.metadata.collection,
keyspace=message.metadata.user,
table=message.metadata.collection,
)
except Exception as e:
print("Exception", e, flush=True)
@ -65,7 +67,7 @@ class Processor(TriplesStoreService):
self.table = table
for t in v.triples:
for t in message.triples:
self.tg.insert(
t.s.value,
t.p.value,