diff --git a/src/nbi/Dockerfile b/src/nbi/Dockerfile index 6bca1c81a5afbaf891b22c7497d230066b750e75..ac54fc851f22672f86bbaaa9e94e8cf534ad30cb 100644 --- a/src/nbi/Dockerfile +++ b/src/nbi/Dockerfile @@ -89,4 +89,5 @@ RUN mkdir -p /var/teraflow/tests/tools COPY src/tests/tools/mock_osm/. tests/tools/mock_osm/ # Start the service -ENTRYPOINT ["gunicorn", "--workers", "4", "--worker-class", "eventlet", "--bind", "0.0.0.0:8080", "nbi.service.app:app"] +# NOTE: Configured single worker to prevent issues with multi-worker synchronization. To be invetsigated. +ENTRYPOINT ["gunicorn", "--workers", "1", "--worker-class", "eventlet", "--bind", "0.0.0.0:8080", "nbi.service.app:app"] diff --git a/src/nbi/service/NbiApplication.py b/src/nbi/service/NbiApplication.py index dee09462c3b48a5c5877ed7df4f6d4b07c95359c..16c1a6a1a53515d365abfd5748a5b479b5c73238 100644 --- a/src/nbi/service/NbiApplication.py +++ b/src/nbi/service/NbiApplication.py @@ -44,13 +44,13 @@ class NbiApplication: # Configure KafkaManager to enable SocketIO Servers running in different # gunicorn workers to self-coordinate and share sessions. - self._sio_client_manager = socketio.KafkaManager( - url='kafka://{:s}'.format(KafkaConfig.get_kafka_address()), - channel=KafkaTopic.NBI_SOCKETIO_WORKERS.value - ) + #self._sio_client_manager = socketio.KafkaManager( + # url='kafka://{:s}'.format(KafkaConfig.get_kafka_address()), + # channel=KafkaTopic.NBI_SOCKETIO_WORKERS.value + #) self._sio = SocketIO( self._app, cors_allowed_origins='*', async_mode='eventlet', - client_manager=self._sio_client_manager, + #client_manager=self._sio_client_manager, logger=True, engineio_logger=True ) diff --git a/src/nbi/service/health_probes/Namespaces.py b/src/nbi/service/health_probes/Namespaces.py index 8a3f9323c3312bd8376bb9839f7ce09c377d22ec..5f6a5205f938c0867c52f7e3b0006e3836069051 100644 --- a/src/nbi/service/health_probes/Namespaces.py +++ b/src/nbi/service/health_probes/Namespaces.py @@ -24,7 +24,7 @@ class HeartbeatServerNamespace(Namespace): def __init__(self): super().__init__(namespace=SIO_NAMESPACE) self._thread = HeartbeatThread(self) - self._thread.start() + #self._thread.start() def stop_thread(self) -> None: self._thread.stop()