Merge pull request #73 from alercebroker/logger-experiment

chore: changed logging in start

apf/core/step.py

@@ -416,15 +416,16 @@ def set_producer_key_field(self, key_field: str):
 
     @profile
     def start(self):
+        logger = logging.getLogger(f"alerce.{self.__class__.__name__}")
         """Start running the step."""
         self._pre_consume()
         for message in self.consumer.consume():
             preprocessed_msg = self._pre_execute(message)
             try:
                 result = self.execute(preprocessed_msg)
             except Exception as error:
-                self.logger.debug("Error at execute")
-                self.logger.debug(f"The message(s) that caused the error: {message}")
+                logger.debug("Error at execute")
+                logger.debug(f"The message(s) that caused the error: {message}")
                 raise error
             result = self._post_execute(result)
             result = self._pre_produce(result)

apf/metrics/pyroscope/profile.py

@@ -6,7 +6,7 @@ def profile(func):
     """ Creates a Pyroscope context for the function to execute """
     @functools.wraps(func)
     def pyroscope_context(*args, **kwargs):
-        if os.getenv("USE_PROFILING"):
+        if bool(os.getenv("USE_PROFILING")):
             with pyroscope.tag_wrapper({ "function": func.__name__ }):
                 func(*args, **kwargs)
 

setup.py

@@ -14,7 +14,7 @@
 
 setup(
     name="apf_base",
-    version="2.5.1",
+    version="2.5.1b",
     description="ALeRCE Alert Processing Framework.",
     long_description=long_description,
     long_description_content_type="text/markdown",