temphum_mqtt_node: scheduler pause/resume

1 files changed, 5 insertions, 0 deletions

diff --git a/bin/temphum_mqtt_node.py b/bin/temphum_mqtt_node.py
index 3f1c911..68ac579 100755
--- a/bin/temphum_mqtt_node.py
+++ b/bin/temphum_mqtt_node.py
@@ -40,12 +40,17 @@ def on_mqtt_connect():
         _scheduler.add_job(on_sched_task, 'interval', seconds=60, next_run_time=datetime.now())
         _scheduler.start()
         _sched_task_added = True
+    elif _scheduler:
+        _scheduler.resume()
 
 
 def on_mqtt_disconnect():
     global _stopped
     _stopped = True
 
+    if _scheduler:
+        _scheduler.pause()
+
 
 async def on_sched_task():
     if _stopped: