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

Create producers before consumers, may streamline startup.

Browse source
This commit is contained in:
Cyber MacGeddon 2024-09-30 12:01:39 +01:00
parent 8c3ac009da
commit e22d174875
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
trustgraph/base/consumer_producer.py
View file

@ -63,16 +63,16 @@ class ConsumerProducer(BaseProcessor):
if output_schema == None: if output_schema == None:
raise RuntimeError("output_schema must be specified") raise RuntimeError("output_schema must be specified")
self.consumer = self.client.subscribe(
input_queue, subscriber,
schema=JsonSchema(input_schema),
)
self.producer = self.client.create_producer( self.producer = self.client.create_producer(
topic=output_queue, topic=output_queue,
schema=JsonSchema(output_schema), schema=JsonSchema(output_schema),
) )
self.consumer = self.client.subscribe(
input_queue, subscriber,
schema=JsonSchema(input_schema),
)
def run(self): def run(self):
__class__.state_metric.state('running') __class__.state_metric.state('running')