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

remove cruft

Browse source
This commit is contained in:
Cyber MacGeddon 2025-07-21 13:14:34 +01:00
parent 63e26dcd53
commit cb096f868c
1 changed files with 0 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -101,7 +101,6 @@ class Processor(FlowProcessor):
tpls.metadata = metadata tpls.metadata = metadata
tpls.triples = triples tpls.triples = triples
print("triples: ", tpls, flush=True)
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):
@ -109,7 +108,6 @@ class Processor(FlowProcessor):
ecs.metadata = metadata ecs.metadata = metadata
ecs.entities = entity_contexts ecs.entities = entity_contexts
print("entity contexts: ", ecs, flush=True)
await pub.send(ecs) await pub.send(ecs)
def parse_json(self, text): def parse_json(self, text):
@ -147,8 +145,6 @@ class Processor(FlowProcessor):
print("Response:", response, flush=True) print("Response:", response, flush=True)
print("Done?", response.answer is not None, flush=True)
if response.error is not None: if response.error is not None:
if response.error.message: if response.error.message:
raise RuntimeError(str(response.error.message)) raise RuntimeError(str(response.error.message))
@ -165,8 +161,6 @@ class Processor(FlowProcessor):
recipient = handle, recipient = handle,
question = prompt question = prompt
) )
print("response:", agent_response, flush=True)
# Parse JSON response # Parse JSON response
try: try:
@ -183,12 +177,6 @@ class Processor(FlowProcessor):
for t in v.metadata.metadata: for t in v.metadata.metadata:
triples.append(t) triples.append(t)
for tpl in triples:
print("TRIPLE>>>", tpl.s, tpl.p, tpl.o)
for ec in entity_contexts:
print("ENTITY CONTEXT>>>", tpl)
# Emit outputs # Emit outputs
if triples: if triples:
await self.emit_triples(flow("triples"), v.metadata, triples) await self.emit_triples(flow("triples"), v.metadata, triples)