fix source logging by defining logger in Sources correctly

src/decisionengine/framework/engine/SourceWorkers.py

@@ -50,19 +50,20 @@ def __init__(self, key, config, logger_config, channel_name, exchange, broker_ur
         :arg config: configuration dictionary describing the worker
         """
         super().__init__(name=f"SourceWorker-{key}")
-        self.module_instance = _create_module_instance(config, Source, channel_name)
         self.config = config
         self.logger_config = logger_config
         self.channel_name = channel_name
         self.module = self.config["module"]
         self.key = key
-        self.class_name = self.module_instance.__class__.__name__
         SOURCE_ACQUIRE_GAUGE.labels(self.key)
 
         self.loglevel = multiprocessing.Value("i", logging.WARNING)
         self.logger = structlog.getLogger(logconf.SOURCELOGGERNAME)
         self.logger.setLevel(logging.DEBUG)
 
+        self.module_instance = _create_module_instance(config, Source, channel_name)
+        self.class_name = self.module_instance.__class__.__name__
+
         logger = structlog.getLogger(logconf.LOGGERNAME)
         logger = logger.bind(module=__name__.split(".")[-1], source=self.key)
 

src/decisionengine/framework/modules/Source.py

@@ -4,6 +4,10 @@
 import pprint
 import sys
 
+import structlog
+
+import decisionengine.framework.modules.logging_configDict as logconf
+
 from decisionengine.framework.config.ValidConfig import ValidConfig
 from decisionengine.framework.modules import describe as _describe
 from decisionengine.framework.modules.describe import Parameter, supports_config
@@ -18,6 +22,8 @@ class Source(Module):
     def __init__(self, set_of_parameters):
         super().__init__(set_of_parameters)
 
+        self.logger = structlog.getLogger(logconf.SOURCELOGGERNAME)
+
     # acquire: The action function for a source. Will
     # retrieve data from external sources and issue a
     # DataBlock "put" transaction.