Merge pull request #839 from onkelandy/knx

knx: Update scheduler calls
smarthomeNG · Oct 31, 2023 · 0ed48ba · 0ed48ba
2 parents 2b653cb + 2e60403
commit 0ed48ba
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/knx/__init__.py b/knx/__init__.py
@@ -249,8 +249,10 @@ def _poll(self, **kwargs):
                 ga = kwargs['ga']
                 interval = int(kwargs['interval'])
                 next = self.shtime.now() + timedelta(seconds=interval)
-                self._sh.scheduler.add(f'KNX poll {item}', self._poll,
-                                    value={'instance': self.get_instance_name(), ITEM: item, 'ga': ga, 'interval': interval},
+                self.scheduler_add(f'KNX poll {item}', self._poll,
+                                    value={'caller': self.get_shortname(),
+                                    'instance': self.get_instance_name(),
+                                    ITEM: item, 'ga': ga, 'interval': interval},
                                     next=next)
             except Exception as ex:
                 self.logger.error(f"_poll function got an error {ex}")
@@ -542,7 +544,7 @@ def run(self):
             self._poll(**{ITEM: item, 'ga':_ga, 'interval':_interval})
 
         if self._send_time_do:
-            self._sh.scheduler.add('KNX[{0}] time'.format(self.get_instance_name()), self._send_time, prio=5, cycle=int(self._send_time_do))
+            self.scheduler_add('KNX[{0}] time'.format(self.get_instance_name()), self._send_time, prio=5, cycle=int(self._send_time_do))
 
     def stop(self):
         """