diff --git a/analytics/server.py b/analytics/server.py index c32ed01..77244bd 100644 --- a/analytics/server.py +++ b/analytics/server.py @@ -18,6 +18,7 @@ server_service: services.ServerService = None data_service: services.DataService = None analytic_unit_manager: AnalyticUnitManager = None +logging.root.setLevel(config.LOGGING_LEVEL) logger = logging.getLogger('SERVER') @@ -88,7 +89,7 @@ def run_server(): #loop.set_debug(True) logger.info("Ok") init_services() - print('Analytics process is running') # we need to print to stdout and flush + logger.info('Analytics process is running') # we need to print to stdout and flush sys.stdout.flush() # because node.js expects it loop.run_until_complete(app_loop()) diff --git a/analytics/services/server_service.py b/analytics/services/server_service.py index 9b3db03..5c49a93 100644 --- a/analytics/services/server_service.py +++ b/analytics/services/server_service.py @@ -111,7 +111,7 @@ class ServerService(utils.concurrent.AsyncZmqActor): self.__server_socket = None # TODO: move to config reconnect_delay = 3 - print('connection is refused or lost, trying to reconnect in %s seconds' % reconnect_delay) + logger.info('connection is refused or lost, trying to reconnect in %s seconds' % reconnect_delay) await asyncio.sleep(reconnect_delay) raise InterruptedError()