Fixed logging messages

alpha-unito · Oct 4, 2024 · 077abc6 · 077abc6
1 parent 7942f06
commit 077abc6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/streamflow/deployment/connector/container.py b/streamflow/deployment/connector/container.py
@@ -1303,7 +1303,7 @@ async def get_available_locations(
             (json_end := output.rfind("}")) != -1
         ):
             if json_start != 0 and logger.isEnabledFor(logging.DEBUG):
-                logger.debug(f"Docker Compose log: {output[:json_start]}")
+                logger.debug(f"Docker Compose log: {output[:json_start].strip()}")
             locations = json.loads(output[json_start : json_end + 1])
         else:
             raise WorkflowExecutionException(

diff --git a/streamflow/workflow/step.py b/streamflow/workflow/step.py
@@ -100,7 +100,7 @@ async def _get_inputs(self, input_ports: MutableMapping[str, Port]):
         if logger.isEnabledFor(logging.DEBUG):
             if check_termination(inputs.values()):
                 logger.debug(
-                    f"Step {self.name} received termination token with Status {_reduce_statuses([t.value for t in inputs.values()]).name.lower()}"
+                    f"Step {self.name} received termination token with Status {_reduce_statuses([t.value for t in inputs.values()]).name}"
                 )
             else:
                 logger.debug(