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

Fix some issues including uploading large docs

Browse source
This commit is contained in:
Cyber MacGeddon 2025-05-05 18:33:32 +01:00
parent 04e0b6953f
commit f68a4f21b1
5 changed files with 10 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
trustgraph-base/trustgraph/base/publisher.py
View file

@ -37,6 +37,7 @@ class Publisher:
while self.running:
try:
producer = self.client.create_producer(
topic=self.topic,
schema=JsonSchema(self.schema),

7
trustgraph-base/trustgraph/schema/library.py
View file

@ -125,10 +125,13 @@ class LibrarianResponse(Record):
document_metadatas = Array(DocumentMetadata())
processing_metadatas = Array(ProcessingMetadata())
# FIXME: Is this right? Using persistence on librarian so that
# message chunking works
librarian_request_queue = topic(
'librarian', kind='non-persistent', namespace='request'
'librarian', kind='persistent', namespace='request'
)
librarian_response_queue = topic(
'librarian', kind='non-persistent', namespace='response',
'librarian', kind='persistent', namespace='response',
)