Format fixes

config.py

@@ -1,6 +1,5 @@
 import yaml
 import os
-import sys
 
 with open(os.path.join(os.path.dirname(os.path.realpath(__file__)), "config.yaml"), "r") as f:
     settings = yaml.safe_load(f)

gateway.py

@@ -19,6 +19,7 @@
 from workers_queue import _WORKERS_QUEUE
 from mqtt import MqttClient
 from workers_manager import WorkersManager
+from config import settings
 
 
 parser = argparse.ArgumentParser()
@@ -61,8 +62,6 @@
     print(' '.join(requirements))
     exit(0)
 
-from config import settings
-
 _LOGGER = logger.get()
 if parsed.quiet:
     _LOGGER.setLevel(logging.WARNING)

mqtt.py

@@ -96,6 +96,7 @@ def availability_topic(self):
     def mqttc(self):
         return self._mqttc
 
+    # noinspection PyUnusedLocal
     def on_connect(self, client, userdata, flags, rc):
         if self.availability_topic:
             self.publish(

workers/lywsd03mmc.py

@@ -1,4 +1,3 @@
-
 import json
 import logger
 
@@ -105,7 +104,7 @@ def subscribe(self, device):
     def handleNotification(self, handle, data):
         temperature = int.from_bytes(data[0:2], byteorder='little', signed=True) / 100
         humidity = int.from_bytes(data[2:3], byteorder='little')
-        battery =  int.from_bytes(data[3:5], byteorder='little') / 1000
+        battery = int.from_bytes(data[3:5], byteorder='little') / 1000
 
         self._temperature = round(temperature, 1)
         self._humidity = round(humidity)

workers/miflora.py

@@ -103,8 +103,6 @@ def config_device(self, name, mac):
     def status_update(self):
         _LOGGER.info("Updating %d %s devices", len(self.devices), repr(self))
 
-        ret = None
-
         for name, data in self.devices.items():
             _LOGGER.debug("Updating %s device '%s' (%s)", repr(self), name, data["mac"])
             from btlewrap import BluetoothBackendException
@@ -121,7 +119,7 @@ def status_update(self):
                     type(e).__name__,
                     suppress=True,
                 )
-            except DeviceTimeoutError as e:
+            except DeviceTimeoutError:
                 logger.log_exception(
                     _LOGGER,
                     "Time out during update of %s device '%s' (%s)",

workers/mithermometer.py

@@ -67,7 +67,7 @@ def config_device(self, name, mac):
 
     def status_update(self):
         _LOGGER.info("Updating %d %s devices", len(self.devices), repr(self))
-        ret = []
+
         for name, data in self.devices.items():
             _LOGGER.debug("Updating %s device '%s' (%s)", repr(self), name, data["mac"])
             from btlewrap import BluetoothBackendException
@@ -84,7 +84,7 @@ def status_update(self):
                     type(e).__name__,
                     suppress=True,
                 )
-            except DeviceTimeoutError as e:
+            except DeviceTimeoutError:
                 logger.log_exception(
                     _LOGGER,
                     "Time out during update of %s device '%s' (%s)",

workers/thermostat.py

@@ -1,6 +1,3 @@
-from builtins import staticmethod
-import logging
-
 from mqtt import MqttMessage, MqttConfigMessage
 
 from workers.base import BaseWorker

workers_manager.py

@@ -14,6 +14,7 @@
 import logger
 
 from pip import __version__ as pip_version
+
 if LooseVersion(pip_version) >= LooseVersion("10"):
     if LooseVersion(pip_version) >= LooseVersion("19.3.1"):
         from pip._internal.main import main as pip_main
@@ -44,12 +45,12 @@ def execute(self):
 
             try:
                 with timeout(
-                    self._timeout,
-                    exception=WorkerTimeoutError(
-                        "Execution of command {} timed out after {} seconds".format(
-                            self._source, self._timeout
-                        )
-                    ),
+                        self._timeout,
+                        exception=WorkerTimeoutError(
+                            "Execution of command {} timed out after {} seconds".format(
+                                self._source, self._timeout
+                            )
+                        ),
                 ):
                     if inspect.isgeneratorfunction(self._callback):
                         for message in self._callback(*self._args):
@@ -112,7 +113,7 @@ def register_workers(self, global_topic_prefix):
 
                 if "update_interval" in worker_config:
                     job_id = "{}_interval_job".format(worker_name)
-                    interval_job = self._scheduler.add_job(
+                    self._scheduler.add_job(
                         partial(self._queue_command, command),
                         "interval",
                         seconds=worker_config["update_interval"],
@@ -205,7 +206,7 @@ def _on_command_wrapper(self, worker_obj, client, userdata, c):
         )
         global_topic_prefix = userdata["global_topic_prefix"]
         topic = (
-            c.topic[len(global_topic_prefix + "/") :]
+            c.topic[len(global_topic_prefix + "/"):]
             if global_topic_prefix is not None
             else c.topic
         )