MySmartHome/bt-mqtt-gateway
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix lambda problem

Browse Source
This commit is contained in:
zewelor
2018-03-05 23:41:07 +01:00
parent 34c0804457
commit b27bad32fa
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
workers_manager.py
+5 -1
View File
@@ -4,6 +4,7 @@ import threading
import pip import pip
from apscheduler.schedulers.background import BackgroundScheduler from apscheduler.schedulers.background import BackgroundScheduler
from interruptingcow import timeout from interruptingcow import timeout
from functools import partial
from logger import _LOGGER from logger import _LOGGER
from workers_queue import _WORKERS_QUEUE from workers_queue import _WORKERS_QUEUE
@@ -59,7 +60,7 @@ class WorkersManager:
_LOGGER.debug("Subscribing to: %s" % worker_config['topic_subscription']) _LOGGER.debug("Subscribing to: %s" % worker_config['topic_subscription'])
self._mqtt_callbacks.append(( self._mqtt_callbacks.append((
worker_config['topic_subscription'], worker_config['topic_subscription'],
lambda client, _ , c: self._queue_command(self.Command(worker_obj.on_command, [c.topic, c.payload])) partial(self._on_command_wrapper, worker_obj)
)) ))
if 'topic_subscription' in config: if 'topic_subscription' in config:
@@ -96,3 +97,6 @@ class WorkersManager:
def _pip_install_helper(package_names): def _pip_install_helper(package_names):
for package in package_names: for package in package_names:
pip.main(['install', '-q', package]) pip.main(['install', '-q', package])
def _on_command_wrapper(self, worker_obj, client, _, c):
self._queue_command(self.Command(worker_obj.on_command, [c.topic, c.payload]))