Update logging.

conML/shared/logger.py

@@ -19,29 +19,36 @@
 
 """
 
+import nrt_logging
+from nrt_logging.logger import NrtLogger
+from nrt_logging.logger_manager import logger_manager
+from nrt_logging.logger_stream_handlers import ManualDepthEnum
 
 import json
 from os.path import join
 from enum import Enum
 
-
 class LogMeMixin:
-    def log_me(self, logger, stdout, json_container):
-        """Log the information gathered during the knowledge search process.
+    def log_me(self):
+        """
+        Log the information gathered during the knowledge search process.
 
         Args:
             logger (logging.Logger):
             stdout (bool): Indicator if it should be logged to console.
             json_container (JsonContainer): Container for the logging
                 information in JSON-Format.
-
         """
-        json_container.log(self)
-
-        if stdout:
-            logger.protocol(self.banner())
-            logger.protocol(str(self))
+        
+        pass
+        #self.__logger = logger_manager.get_logger("LOGME")
+        #self.__logger.snapshot()
+        
+        # json_container.log(self)
 
+        # if stdout:
+        #     logger.protocol(self.banner())
+        #     logger.protocol(str(self))
 
 class BlockProcessInfo(LogMeMixin):
     """Holds logging information of the block pulling process.
@@ -60,6 +67,8 @@ class BlockProcessInfo(LogMeMixin):
         self.n_rows = n_rows
         self.n_columns = n_columns
 
+        logger_manager.get_logger("LOGME").snapshot()
+
     def __str__(self):
         return "\n".join([
             "{: <20}{}".format("Rows", str(self.n_rows)),
@@ -103,6 +112,8 @@ class LearnblockIdentificationInfo(LogMeMixin):
         self.n_columns = n_columns
         self.relationship = relationship
 
+        logger_manager.get_logger("LOGME").snapshot()
+
     def __str__(self):
         return "\n".join([
             "{: <20}{}".format("State", str(self.state)),
@@ -140,6 +151,8 @@ class HighLevelLearnblockInfo(LogMeMixin):
         self.n_rows = lb.n_rows()
         self.n_columns = lb.n_columns()
         self.origin = lb.origin
+        
+        logger_manager.get_logger("LOGME").snapshot()
 
     def __str__(self):
         return "\n".join([
@@ -199,6 +212,8 @@ class ConstructionInfo(LogMeMixin):
             self.relationship = str(learnblock.relationship)
             self.lb_subject = learnblock.subject if learnblock.subject else ""
 
+        logger_manager.get_logger("LOGME").snapshot()
+
     def __str__(self):
         if self.state == self.State.PASSED:
             return "\n".join([
@@ -267,6 +282,8 @@ class SelectionInfo(LogMeMixin):
         self.n_rows = learnblock.n_rows()
         self.n_columns = learnblock.n_columns(effective=True)
 
+        logger_manager.get_logger("LOGME").snapshot()
+
     def __str__(self):
         return "\n".join([
             "{: <20}{}".format("State", str(self.state)),
@@ -315,6 +332,8 @@ class ReconstructionInfo(LogMeMixin):
         self.subject = subject
         self.reliability = reliability
 
+        logger_manager.get_logger("LOGME").snapshot()
+
     def __str__(self):
         if self.state == ReconstructionInfo.State.RECONSTRUCTED:
             return "\n".join([
@@ -373,6 +392,8 @@ class WinnerSelectionInfo(LogMeMixin):
         self.accuracy = accuracy
         self.reliability = reliability
 
+        logger_manager.get_logger("LOGME").snapshot()
+
     def __str__(self):
         state_info = "{: <20}{}".format("State", str(self.state))
         if self.state == self.State.SELECTED:
@@ -434,6 +455,8 @@ class DeconstructionInfo(LogMeMixin):
         self.deleted = deleted if deleted else []
         self.inserted = inserted if inserted else []
         self.new_learnblock = new_learnblock
+        
+        logger_manager.get_logger("LOGME").snapshot()
 
     def __str__(self):
         msg = ""

requirements.txt

@@ -8,3 +8,4 @@ scikit-learn==0.23.2
 scipy==1.6.1
 six==1.15.0
 sklearn==0.0
+nrt-logging==1.3.4
\ No newline at end of file