From f9e324eae0f9f5a6b8551f425136f578a50e20d3 Mon Sep 17 00:00:00 2001 From: psrok1 Date: Wed, 10 Sep 2025 19:40:10 +0200 Subject: [PATCH] Fix: missing record.task_id for descendant loggers (e.g. karton..module) --- karton/core/base.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/karton/core/base.py b/karton/core/base.py index 2504d6fc..75c3d605 100644 --- a/karton/core/base.py +++ b/karton/core/base.py @@ -131,11 +131,11 @@ def setup_logger(self, level: Optional[Union[str, int]] = None) -> None: if not self.identity: raise ValueError("Can't setup logger without identity") + task_context_filter = TaskContextFilter() self._log_handler.setFormatter(logging.Formatter()) + self._log_handler.addFilter(task_context_filter) logger = logging.getLogger(self.identity) - logger.addFilter(TaskContextFilter()) - if logger.handlers: # If logger already have handlers set: clear them logger.handlers.clear() @@ -148,6 +148,7 @@ def setup_logger(self, level: Optional[Union[str, int]] = None) -> None: logger.setLevel(log_level) stream_handler = logging.StreamHandler() stream_handler.setFormatter(logging.Formatter(self._log_format)) + stream_handler.addFilter(task_context_filter) logger.addHandler(stream_handler) if not self.debug and self.enable_publish_log: