Fix missing queue initialisation

This commit is contained in:
Cyber MacGeddon 2025-05-17 13:01:52 +01:00
parent da4caa863f
commit 410636b409
4 changed files with 11 additions and 0 deletions

View file

@ -22,6 +22,9 @@ class DocumentEmbeddingsImport:
pulsar_client, topic = queue, schema = DocumentEmbeddings
)
async def start(self):
await self.publisher.start()
async def destroy(self):
self.running.stop()

View file

@ -22,6 +22,9 @@ class GraphEmbeddingsImport:
pulsar_client, topic = queue, schema = GraphEmbeddings
)
async def start(self):
await self.publisher.start()
async def destroy(self):
self.running.stop()

View file

@ -160,6 +160,8 @@ class DispatcherManager:
queue = qconfig,
)
await dispatcher.start()
return dispatcher
async def process_flow_export(self, ws, running, params):

View file

@ -22,6 +22,9 @@ class TriplesImport:
pulsar_client, topic = queue, schema = Triples
)
async def start(self):
await self.publisher.start()
async def destroy(self):
self.running.stop()