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

GOt it working

Browse source
This commit is contained in:
Cyber MacGeddon 2025-02-11 23:03:16 +00:00
parent 29f209980a
commit faa50cbcdc
3 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-flow/trustgraph/embeddings/document_embeddings/embeddings.py
View file

@ -73,7 +73,7 @@ class Processor(ConsumerProducer):
chunks=embeds,
)
await self.producer.send(r)
await self.send(r)
except Exception as e:
print("Exception:", e, flush=True)

2
trustgraph-flow/trustgraph/embeddings/graph_embeddings/embeddings.py
View file

@ -77,7 +77,7 @@ class Processor(ConsumerProducer):
entities=entities,
)
await self.producer.send(r)
await self.send(r)
except Exception as e:
print("Exception:", e, flush=True)

2
trustgraph-flow/trustgraph/extract/kg/definitions/extract.py
View file

@ -110,7 +110,7 @@ class Processor(ConsumerProducer):
metadata=metadata,
entities=entities,
)
await self.ec_prod.send(t)
self.ec_prod.send(t)
async def handle(self, msg):