Fixup set update

lsst-sqre · Oct 5, 2021 · e41f701 · e41f701
1 parent e644624
commit e41f701
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/kafkaaggregator/aggregator_config.py b/src/kafkaaggregator/aggregator_config.py
@@ -164,7 +164,7 @@ def source_topics(self) -> Set:
         """Return all source topics in the aggregator config."""
         source_topics: Set = set()
         for topic in self._config.aggregated_topics:
-            source_topics.add(topic.source_topics)
+            source_topics.update(topic.source_topics)
         return source_topics
 
     def get(self, aggregated_topic: str) -> AggregatedTopic: