X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=ms%2Fpy-executor%2Fserver.py;fp=ms%2Fpy-executor%2Fserver.py;h=5df6f9350605868312f2a393b10feee511e07f47;hb=adcd4f2bc695840e9ecbc05003bc52c675f22fec;hp=7f6537011bf4a51196449102bcdb5ce5331dbd1c;hpb=dc8252f3cfa1ddd0c1c8c70513c16c738d840822;p=ccsdk%2Fcds.git diff --git a/ms/py-executor/server.py b/ms/py-executor/server.py index 7f6537011..5df6f9350 100644 --- a/ms/py-executor/server.py +++ b/ms/py-executor/server.py @@ -24,10 +24,10 @@ from pathlib import Path, PurePath import grpc from manager.servicer import ArtifactManagerServicer -from proto.BluePrintManagement_pb2_grpc import add_BluePrintManagementServiceServicer_to_server +from proto.BlueprintManagement_pb2_grpc import add_BlueprintManagementServiceServicer_to_server -from blueprints_grpc import BluePrintProcessing_pb2_grpc, ScriptExecutorConfiguration -from blueprints_grpc.blueprint_processing_server import BluePrintProcessingServer +from blueprints_grpc import BlueprintProcessing_pb2_grpc, ScriptExecutorConfiguration +from blueprints_grpc.blueprint_processing_server import BlueprintProcessingServer from blueprints_grpc.request_header_validator_interceptor import RequestHeaderValidatorInterceptor logger = logging.getLogger("Server") @@ -56,10 +56,10 @@ def serve(configuration: ScriptExecutorConfiguration): # create server server = grpc.server(futures.ThreadPoolExecutor(max_workers=int(maxWorkers))) - BluePrintProcessing_pb2_grpc.add_BluePrintProcessingServiceServicer_to_server( - BluePrintProcessingServer(configuration), server + BlueprintProcessing_pb2_grpc.add_BlueprintProcessingServiceServicer_to_server( + BlueprintProcessingServer(configuration), server ) - add_BluePrintManagementServiceServicer_to_server(ArtifactManagerServicer(), server) + add_BlueprintManagementServiceServicer_to_server(ArtifactManagerServicer(), server) # add secure port using credentials server.add_secure_port('[::]:' + port, server_credentials) @@ -73,10 +73,10 @@ def serve(configuration: ScriptExecutorConfiguration): # create server with token authentication interceptors server = grpc.server(futures.ThreadPoolExecutor(max_workers=int(maxWorkers)), interceptors=(header_validator,)) - BluePrintProcessing_pb2_grpc.add_BluePrintProcessingServiceServicer_to_server( - BluePrintProcessingServer(configuration), server + BlueprintProcessing_pb2_grpc.add_BlueprintProcessingServiceServicer_to_server( + BlueprintProcessingServer(configuration), server ) - add_BluePrintManagementServiceServicer_to_server(ArtifactManagerServicer(), server) + add_BlueprintManagementServiceServicer_to_server(ArtifactManagerServicer(), server) server.add_insecure_port('[::]:' + port) server.start()