Merge pull request #44 from jbellister-slac/fix_pydm_plugin

FIX: Set kafka topic list correctly in the pydm plugin
slaclab · Mar 2, 2023 · a53a6a1 · a53a6a1
2 parents 4181881 + c30ee02
commit a53a6a1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pydm_alarm_plugin/alarm_plugin.py b/pydm_alarm_plugin/alarm_plugin.py
@@ -79,10 +79,10 @@ def __init__(self, *args, **kwargs):
             return
 
         self.alarm_severities = dict()  # Mapping from alarm name to current alarm severity
-        self.kafka_reader = KafkaReader(kafka_topics.split(','),
+        self.kafka_topics = kafka_topics.split(',')
+        self.kafka_reader = KafkaReader(self.kafka_topics,
                                         kafka_bootstrap_servers.split(','),
                                         self.process_message)
-        self.kafka_topics = kafka_topics
         self.processing_thread = QThread()
         self.kafka_reader.moveToThread(self.processing_thread)
         self.processing_thread.started.connect(self.kafka_reader.run)