From e50a12bc5c1026b0440f8de94f3d6259dad55140 Mon Sep 17 00:00:00 2001 From: zewelor Date: Wed, 6 Dec 2017 10:25:32 +0100 Subject: [PATCH] Allow disable topic subscription from config --- workers_manager.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/workers_manager.py b/workers_manager.py index 0cbdc07..8ab700e 100644 --- a/workers_manager.py +++ b/workers_manager.py @@ -54,12 +54,13 @@ class WorkersManager: lambda client, _ , c: self._queue_command(self.Command(worker_obj.on_command, [c.topic, c.payload])) )) - for (callback_name, options) in config['topic_subcription'].items(): - _LOGGER.debug("Subscribing to: %s with command: %s" % (options['topic'], callback_name)) - self._mqtt_callbacks.append(( - options['topic'], - lambda client, _ , c: self._queue_if_matching_payload(self.Command(getattr(self, callback_name)), c.payload, options['payload'])) - ) + if 'topic_subscription' in config: + for (callback_name, options) in config['topic_subcription'].items(): + _LOGGER.debug("Subscribing to: %s with command: %s" % (options['topic'], callback_name)) + self._mqtt_callbacks.append(( + options['topic'], + lambda client, _ , c: self._queue_if_matching_payload(self.Command(getattr(self, callback_name)), c.payload, options['payload'])) + ) return self