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_client.py b/osm_ee/frontend_client.py
index 0c34580..21203a2 100644
--- a/osm_ee/frontend_client.py
+++ b/osm_ee/frontend_client.py
@@ -24,13 +24,11 @@
import yaml
import asyncio
import uuid
-import traceback
-import os
import socket
from grpclib.client import Channel
-from osm_ee.frontend_pb2 import PrimitiveRequest, PrimitiveReply
+from osm_ee.frontend_pb2 import PrimitiveRequest
from osm_ee.frontend_pb2 import SshKeyRequest, SshKeyReply
from osm_ee.frontend_grpc import FrontendExecutorStub
@@ -42,7 +40,7 @@
try:
stub = FrontendExecutorStub(channel)
- if (primitive_name == "get_ssh_key"):
+ if primitive_name == "get_ssh_key":
print("Get ssh key")
reply: SshKeyReply = await stub.GetSshKey(SshKeyRequest())
print(reply.message)
@@ -51,22 +49,25 @@
primitive_id = str(uuid.uuid1())
print("Execute primitive {}, params: {}".format(primitive_name, params))
await stream.send_message(
- PrimitiveRequest(id=primitive_id, name=primitive_name, params=yaml.dump(params)), end=True)
+ PrimitiveRequest(
+ id=primitive_id, name=primitive_name, params=yaml.dump(params)
+ ),
+ end=True,
+ )
async for reply in stream:
print(reply)
- #replies = [reply async for reply in stream]
- #print(replies)
+ # replies = [reply async for reply in stream]
+ # print(replies)
except Exception as e:
print("Error executing primitive {}: {}".format(primitive_name, str(e)))
- #print(traceback.format_exc())
finally:
channel.close()
-if __name__ == '__main__':
+if __name__ == "__main__":
args = sys.argv[1:]
- if (len(args) < 1):
+ if len(args) < 1:
print("Usage: host port primitive_name params")
else:
host_name = args[0]
@@ -79,7 +80,9 @@
loop = asyncio.get_event_loop()
try:
- task = asyncio.ensure_future(frontend_client(host_name, port, primitive_name, params))
+ task = asyncio.ensure_future(
+ frontend_client(host_name, port, primitive_name, params)
+ )
loop.run_until_complete(task)
finally:
loop.close()