Restyled by autopep8

Author: restyled-commits

run_example_service.py

@@ -32,17 +32,17 @@ def main():
                         help="start the daemon with SSL")
     args = parser.parse_args()
     root_path = pathlib.Path(__file__).absolute().parent
-    
+
     # All services modules go here
     service_modules = ["service.example_service"]
-    
+
     # Call for all the services listed in service_modules
     all_p = start_all_services(root_path,
                                service_modules,
                                args.run_daemon,
                                args.daemon_config,
                                args.run_ssl)
-    
+
     # Continuous checking all subprocess
     try:
         while True:
@@ -77,7 +77,7 @@ def start_service(cwd, service_module, run_daemon, daemon_config, run_ssl):
     Starts SNET Daemon ("snetd") and the python module of the service
     at the passed gRPC port.
     """
-    
+
     def add_ssl_configs(conf):
         """Add SSL keys to snetd.config.json"""
         with open(conf, "r") as f:
@@ -86,7 +86,7 @@ def add_ssl_configs(conf):
             snetd_configs["ssl_key"] = "/opt/singnet/.certs/privkey.pem"
         with open(conf, "w") as f:
             json.dump(snetd_configs, f, sort_keys=True, indent=4)
-    
+
     all_p = []
     if run_daemon:
         if daemon_config:
@@ -102,7 +102,7 @@ def add_ssl_configs(conf):
         sys.executable,
         "-m", service_module,
         "--grpc-port", str(grpc_port)],
-       cwd=str(cwd))
+        cwd=str(cwd))
     all_p.append(p)
     return all_p
 

service/example_service.py

@@ -54,6 +54,8 @@
 
 # Create a class to be added to the gRPC server
 # derived from the protobuf codes.
+
+
 class CalculatorServicer(grpc_bt_grpc.CalculatorServicer):
     def __init__(self):
         self.a = 0
@@ -74,7 +76,8 @@ def add(self, request, context):
         self.result = Result()
 
         self.result.value = self.a + self.b
-        _LOGGER.debug("add({},{})={}".format(self.a, self.b, self.result.value))
+        _LOGGER.debug("add({},{})={}".format(
+            self.a, self.b, self.result.value))
         return self.result
 
     def sub(self, request, context):
@@ -83,7 +86,8 @@ def sub(self, request, context):
 
         self.result = Result()
         self.result.value = self.a - self.b
-        _LOGGER.debug("sub({},{})={}".format(self.a, self.b, self.result.value))
+        _LOGGER.debug("sub({},{})={}".format(
+            self.a, self.b, self.result.value))
         return self.result
 
     def mul(self, request, context):
@@ -92,7 +96,8 @@ def mul(self, request, context):
 
         self.result = Result()
         self.result.value = self.a * self.b
-        _LOGGER.debug("mul({},{})={}".format(self.a, self.b, self.result.value))
+        _LOGGER.debug("mul({},{})={}".format(
+            self.a, self.b, self.result.value))
         return self.result
 
     def div(self, request, context):
@@ -101,7 +106,8 @@ def div(self, request, context):
 
         self.result = Result()
         self.result.value = self.a / self.b
-        _LOGGER.debug("div({},{})={}".format(self.a, self.b, self.result.value))
+        _LOGGER.debug("div({},{})={}".format(
+            self.a, self.b, self.result.value))
         return self.result
 
 
@@ -145,6 +151,7 @@ def reserve_port(grpc_port=7777):
     finally:
         sock.close()
 
+
 def main():
     """ Runs the gRPC server to communicate with the SNET Daemon. """
     parser = argparse.ArgumentParser(prog=__file__)

test_example_service.py

@@ -22,7 +22,8 @@
             endpoint = "localhost:{}".format(
                 registry["example_service"]["grpc"])
 
-        grpc_method = input("Method (add|sub|mul|div): ") if not test_flag else "mul"
+        grpc_method = input(
+            "Method (add|sub|mul|div): ") if not test_flag else "mul"
         a = float(input("Number 1: ") if not test_flag else "12")
         b = float(input("Number 2: ") if not test_flag else "7")