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

Tweaked metadata to reduce unnecessary

Browse source
This commit is contained in:
Cyber MacGeddon 2025-07-21 14:01:28 +01:00
parent 8655152ab4
commit e1ced377eb
1 changed files with 18 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

24
trustgraph-flow/trustgraph/extract/kg/agent/extract.py
View file

@ -97,16 +97,28 @@ class Processor(FlowProcessor):
return TRUSTGRAPH_ENTITIES + urllib.parse.quote(text) return TRUSTGRAPH_ENTITIES + urllib.parse.quote(text)
async def emit_triples(self, pub, metadata, triples): async def emit_triples(self, pub, metadata, triples):
tpls = Triples() tpls = Triples(
tpls.metadata = metadata metadata = Metadata(
tpls.triples = triples id = metadata.id,
metadata = [],
user = metadata.user,
collection = metadata.collection,
),
triples = triples,
)
await pub.send(tpls) await pub.send(tpls)
async def emit_entity_contexts(self, pub, metadata, entity_contexts): async def emit_entity_contexts(self, pub, metadata, entity_contexts):
ecs = EntityContexts() ecs = EntityContexts(
ecs.metadata = metadata metadata = Metadata(
ecs.entities = entity_contexts id = metadata.id,
metadata = [],
user = metadata.user,
collection = metadata.collection,
),
entities = entity_contexts,
)
await pub.send(ecs) await pub.send(ecs)