Possible gc related fix
This commit is contained in:
+2
-1
@@ -26,7 +26,8 @@ else:
|
|||||||
_LOGGER.debug('Starting')
|
_LOGGER.debug('Starting')
|
||||||
|
|
||||||
mqtt = MqttClient(settings['mqtt'])
|
mqtt = MqttClient(settings['mqtt'])
|
||||||
WorkersManager().register_workers(settings['manager']).start(mqtt)
|
manager = WorkersManager()
|
||||||
|
manager.register_workers(settings['manager']).start(mqtt)
|
||||||
|
|
||||||
running = True
|
running = True
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -65,8 +65,8 @@ class WorkersManager:
|
|||||||
return self
|
return self
|
||||||
|
|
||||||
def start(self, mqtt):
|
def start(self, mqtt):
|
||||||
self._scheduler.start()
|
|
||||||
mqtt.callbacks_subscription(self._mqtt_callbacks)
|
mqtt.callbacks_subscription(self._mqtt_callbacks)
|
||||||
|
self._scheduler.start()
|
||||||
self.update_all()
|
self.update_all()
|
||||||
|
|
||||||
def _queue_if_matching_payload(self, command, payload, expected_payload):
|
def _queue_if_matching_payload(self, command, payload, expected_payload):
|
||||||
|
|||||||
Reference in New Issue
Block a user