Format code with yapf

src/centralnode.py

@@ -6,14 +6,15 @@
 import logging
 from Crypto.Util.number import size
 
-
 log = logging.getLogger('central')
 ch = logging.NullHandler()
 ch.setLevel(logging.DEBUG)
-formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+formatter = logging.Formatter(
+    '%(asctime)s - %(name)s - %(levelname)s - %(message)s')
 ch.setFormatter(formatter)
 log.addHandler(ch)
 
+
 class ConfigError(Exception):
     def __init__(self):
         self.message = "Can not config"
@@ -65,9 +66,9 @@ def send(self, payload, dest_slave, quant):
         frame = self.build_send_frame(payload, dest_slave)
         #self.ser = serial.Serial(self.lora_port, timeout=14)
         self.ser.write(bytearray(frame))
-        result = self.ser.read(size =8)
+        result = self.ser.read(size=8)
         log.debug("Data sent : %s", str(frame))
-        self.expected_size = 22 + 2 * quant -8
+        self.expected_size = 22 + 2 * quant - 8
         return result
 
     def receive(self):
@@ -94,8 +95,7 @@ def config_trama(self):
 
     def init_lora(self):
 
-        expect = [
-            1, 0, 129, 12, 165, 165, 108, 64, 18, 7, 0, 0, 1, 1, 0, 3, 0]
+        expect = [1, 0, 129, 12, 165, 165, 108, 64, 18, 7, 0, 0, 1, 1, 0, 3, 0]
         try:
             expect[12] = self.networkid
             check_sum = reduce(lambda x, y: x ^ y, expect)
@@ -114,11 +114,11 @@ def init_lora(self):
             os._exit(0)
         if list(response) != expect:
             expect[3] = 13
-            expect[17] = expect[17]+1
+            expect[17] = expect[17] + 1
             if list(response) == expect:
-                    self.ser.close()
-                    log.info("Lora Config Successfull")
-                    return True
+                self.ser.close()
+                log.info("Lora Config Successfull")
+                return True
             return False
         self.ser.close()
         log.info("Lora Config Successfull")
@@ -137,5 +137,3 @@ def quantity_poll(self):
         if self.lastpollsize != 0:
             n += 1
         return n
-
-

src/main.py

@@ -16,24 +16,32 @@
 from threading import Timer
 
 send_pre = [5, 0, 1, 14, 0, 2, 0, 7, 1, 8]
-
-def post_thread(): 
+
+
+def post_thread():
     global counter
     global post_time_s
-    counter+=1
-    log.info("Posting in %s s",str(post_time_s - counter + 1))
-    if counter == post_time_s :
-        post_scada(node.post_path,args.production)
+    counter += 1
+    log.info("Posting in %s s", str(post_time_s - counter + 1))
+    if counter == post_time_s:
+        post_scada(node.post_path, args.production)
         counter = 0
-    post_timer = Timer(1.0,post_thread)
+    post_timer = Timer(1.0, post_thread)
     post_timer.start()
-    
+
 
 def build_argparser():
     label = subprocess.check_output(["git", "describe"]).strip()
     parser = argparse.ArgumentParser(description="To select production code")
-    parser.add_argument('-p','--production', action='store_true', default=False, help = "Create production code")
-    parser.add_argument('-v','--version', action='version', version=label.decode("utf-8"))
+    parser.add_argument('-p',
+                        '--production',
+                        action='store_true',
+                        default=False,
+                        help="Create production code")
+    parser.add_argument('-v',
+                        '--version',
+                        action='version',
+                        version=label.decode("utf-8"))
     return parser
 
 
@@ -90,7 +98,7 @@ def poll_loras(loras):
 
 
 if __name__ == "__main__":
-    
+
     args = build_argparser().parse_args()
     log = build_logger()
 
@@ -106,13 +114,13 @@ def poll_loras(loras):
         f_post_boot(node.loras, node.post_path)
         counter = 0
         post_time_s = node.post_time
-        post_timer = Timer(1.0,post_thread)
+        post_timer = Timer(1.0, post_thread)
         post_timer.start()
         node.ser = serial.Serial(node.lora_port, timeout=14)
         wtd_start.stop()
     except Watchdog:
         log.error("Reseting script due to wdt boot")
-    wtd = Watchdog(300) # 5min
+    wtd = Watchdog(300)  # 5min
     try:
         while True:
             poll_loras(node.loras)
@@ -129,4 +137,4 @@ def poll_loras(loras):
         log.error("App Crashed!")
         log.error("Problems? %s", sys.exc_info())
         log.info("Restarting...")
-        os.execv(sys.executable, ['python'] + sys.argv)        
+        os.execv(sys.executable, ['python'] + sys.argv)