try fix intervaltrigger bug in linux

Author: MatthieuRochette

DeviceManager/devices/temperature_sensor.py

@@ -4,6 +4,8 @@
 import random
 
 from apscheduler.schedulers.background import BackgroundScheduler
+from apscheduler.triggers.interval import IntervalTrigger
+
 
 from DeviceManager.config import *
 from DeviceManager.protocols.http_protocol import http_protocol
@@ -23,7 +25,9 @@ class TemperatureSensor:
     def __init__(self, token: str, scheduler: BackgroundScheduler) -> None:
         self._token: str = token
         self._scheduler = scheduler
-        self._job = self._scheduler.add_job(self.send, "interval", seconds=1)
+        self._job = self._scheduler.add_job(
+            self.send, trigger=IntervalTrigger(seconds=1)
+        )
         self._temperature: float = 0.0
         self._humidity: int = 0
         self.generateData()

DeviceManager/light_mqtt.py

@@ -1,12 +1,14 @@
 #!/usr/bin/env python3
 
-import paho.mqtt.client as mqtt
+import json
+import threading
 
-from apscheduler.schedulers.background import BackgroundScheduler
+import paho.mqtt.client as mqtt
 from apscheduler.schedulers import SchedulerAlreadyRunningError
+from apscheduler.schedulers.background import BackgroundScheduler
+from apscheduler.triggers.interval import IntervalTrigger
+
 from .devices import LightSensor
-import threading
-import json
 
 
 class LightMqtt:
@@ -56,6 +58,7 @@ def receiver(self):
         """
         Receive data form thingsboard controller.
         """
+
         def wrapper(client, user_data, msg):
             """
             Call light sensor method to change the state, the intensity and the color temperature.
@@ -93,7 +96,7 @@ def start(self):
         self.client.subscribe(self.topicRecived)
         self.client.on_message = self.receiver()
         self.job = self.scheduler.add_job(
-            self.send, "interval", seconds=LightMqtt._socketTimes
+            self.send, trigger=IntervalTrigger(seconds=LightMqtt._socketTimes)
         )
         try:
             self.scheduler.start()
@@ -105,6 +108,6 @@ def stopThread(self):
         """
         Stop all asynchronous processus.
         """
-        self.scheduler.remove_job(self.job.id)
+        self.scheduler.remove_all_jobs()
         self.client.disconnect()
         self.thread.join()