Skip to content
Snippets Groups Projects
Commit 304ecc9c authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Fixing Gitlab CI for Compute component

parent a81f447b
No related branches found
No related tags found
2 merge requests!142Release TeraFlowSDN 2.1,!70Add IETF Slice NBI
...@@ -24,9 +24,9 @@ class ComputeService: ...@@ -24,9 +24,9 @@ class ComputeService:
self.server = None self.server = None
def start(self): def start(self):
self.endpoint = '{}:{}'.format(self.address, self.port) self.endpoint = '{:s}:{:s}'.format(str(self.address), str(self.port))
LOGGER.debug('Starting Service (tentative endpoint: {}, max_workers: {})...'.format( LOGGER.debug('Starting Service (tentative endpoint: {:s}, max_workers: {:s})...'.format(
self.endpoint, self.max_workers)) str(self.endpoint), str(self.max_workers)))
self.pool = futures.ThreadPoolExecutor(max_workers=self.max_workers) self.pool = futures.ThreadPoolExecutor(max_workers=self.max_workers)
self.server = grpc.server(self.pool) # , interceptors=(tracer_interceptor,)) self.server = grpc.server(self.pool) # , interceptors=(tracer_interceptor,))
...@@ -39,15 +39,15 @@ class ComputeService: ...@@ -39,15 +39,15 @@ class ComputeService:
add_HealthServicer_to_server(self.health_servicer, self.server) add_HealthServicer_to_server(self.health_servicer, self.server)
port = self.server.add_insecure_port(self.endpoint) port = self.server.add_insecure_port(self.endpoint)
self.endpoint = '{}:{}'.format(self.address, port) self.endpoint = '{:s}:{:s}'.format(str(self.address), str(port))
LOGGER.info('Listening on {}...'.format(self.endpoint)) LOGGER.info('Listening on {:s}...'.format(str(self.endpoint)))
self.server.start() self.server.start()
self.health_servicer.set(OVERALL_HEALTH, HealthCheckResponse.SERVING) # pylint: disable=maybe-no-member self.health_servicer.set(OVERALL_HEALTH, HealthCheckResponse.SERVING) # pylint: disable=maybe-no-member
LOGGER.debug('Service started') LOGGER.debug('Service started')
def stop(self): def stop(self):
LOGGER.debug('Stopping service (grace period {} seconds)...'.format(self.grace_period)) LOGGER.debug('Stopping service (grace period {:s} seconds)...'.format(str(self.grace_period)))
self.health_servicer.enter_graceful_shutdown() self.health_servicer.enter_graceful_shutdown()
self.server.stop(self.grace_period) self.server.stop(self.grace_period)
LOGGER.debug('Service stopped') LOGGER.debug('Service stopped')
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment