use ability to use session name in ers

Author: emmuhamm

src/drunc/controller/controller.py

@@ -231,7 +231,7 @@ def __init__(self, configuration, name: str, session: str, token: Token):
         self.broadcast_service = None
         self.monitoring_metrics = ControllerMonitoringMetrics()
         self.handlerconf = LogHandlerConf(init_ers=True)
-        self.log = get_logger(f"controller.core.{name}_ctrl", ers_kafka_handler=True)
+        self.log = get_logger(f"controller.core.{name}_ctrl", ers_kafka_handler=session)
         log_init = get_logger("controller.core.__init__")
         log_init.info(f"Initialising controller '{name}' with session '{session}'")
 

src/drunc/process_manager/process_manager.py

@@ -61,7 +61,7 @@ def __init__(
         self.handlerconf = LogHandlerConf(init_ers=True)
         self.log = get_logger(
             f"process_manager.{configuration.get_data_type_name()}_process_manager",
-            ers_kafka_handler=True,
+            ers_kafka_handler=session,
         )
         self.log.debug(pid_info_str())
         self.log.debug("Initialized ProcessManager")