Basic subscriber/ publisher pattern implementation

topic_manager.py

import logging
from collections import defaultdict


class TopicManager:
    def __init__(self):
        self.subscribers = defaultdict(set)

    def subscribe(self, topic, callback):
        """Subscribes a callback function to a topic"""
        self.subscribers[topic].add(callback)
        logging.debug(f'Subscribed {callback} to {topic}')

    def notify(self, topic, *data, **kwdata):
        """Calls every callback for a specified topic while passing data"""
        for sub in self.subscribers[topic]:
            try:
                sub(*data, **kwdata)
            except:
                logging.exception(f'Callback "{sub}", subscribed to '
                                  f'"{topic}", raised an exception when called '
                                  f'with args:{data}, kwargs:{kwdata}')