Fix flake8, black and pylint errors in code
Change-Id: Ic03f4d31e2ba9801be20d3679bd5749948cab39d
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>
diff --git a/osm_ee/frontend_server.py b/osm_ee/frontend_server.py
index 32b3afe..a36594f 100644
--- a/osm_ee/frontend_server.py
+++ b/osm_ee/frontend_server.py
@@ -39,21 +39,31 @@
class FrontendExecutor(FrontendExecutorBase):
def __init__(self):
- self.logger = logging.getLogger('osm_ee.frontend_server')
+ self.logger = logging.getLogger("osm_ee.frontend_server")
self.base_ee = BaseEE()
- async def RunPrimitive(self, stream: Stream[PrimitiveRequest, PrimitiveReply]) -> None:
+ async def RunPrimitive(
+ self, stream: Stream[PrimitiveRequest, PrimitiveReply]
+ ) -> None:
request = await stream.recv_message()
try:
- self.logger.debug(f'Run primitive: id {request.id}, name: {request.name}, params: {request.params}')
- async for status, detailed_message in self.base_ee.run_action(request.id, request.name, request.params):
- self.logger.debug(f'Send response {status}, {detailed_message}')
+ self.logger.debug(
+ f"Run primitive: id {request.id}, name: {request.name}, params: {request.params}"
+ )
+ async for status, detailed_message in self.base_ee.run_action(
+ request.id, request.name, request.params
+ ):
+ self.logger.debug(f"Send response {status}, {detailed_message}")
await stream.send_message(
- PrimitiveReply(status=status, detailed_message=detailed_message))
+ PrimitiveReply(status=status, detailed_message=detailed_message)
+ )
except Exception as e:
- self.logger.debug(f'Error executing primitive: id {request.id}, name: {request.name}, error_msg: {str(e)}')
+ self.logger.debug(
+ f"Error executing primitive: id {request.id}, name: {request.name}, error_msg: {str(e)}"
+ )
await stream.send_message(
- PrimitiveReply(status="ERROR", detailed_message=str(e)))
+ PrimitiveReply(status="ERROR", detailed_message=str(e))
+ )
async def GetSshKey(self, stream: Stream[SshKeyRequest, SshKeyReply]) -> None:
request = await stream.recv_message()
@@ -62,9 +72,9 @@
await stream.send_message(SshKeyReply(message=message))
-async def main(*, host: str = '0.0.0.0', port: int = 50051) -> None:
+async def main(*, host: str = "0.0.0.0", port: int = 50051) -> None:
logging.basicConfig()
- logger = logging.getLogger('osm_ee')
+ logger = logging.getLogger("osm_ee")
logger.setLevel(logging.DEBUG)
# Generate ssh key
@@ -77,11 +87,11 @@
server = Server([FrontendExecutor()])
with graceful_exit([server]):
await server.start(host, port, ssl=util_grpc.create_secure_context())
- logging.getLogger('osm_ee.frontend_server').debug(f'Serving on {host}:{port}')
+ logging.getLogger("osm_ee.frontend_server").debug(f"Serving on {host}:{port}")
await server.wait_closed()
-if __name__ == '__main__':
+if __name__ == "__main__":
loop = asyncio.get_event_loop()
try:
main_task = asyncio.ensure_future(main())