From 523b286ae5f6822cf06519700bbf4e4373f76aba Mon Sep 17 00:00:00 2001 From: BXY0414 <1079823339@qq.com> Date: Tue, 12 May 2026 11:36:16 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=20=E6=8A=A5=E9=94=99+?= =?UTF-8?q?=E9=87=8D=E5=A4=8D=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- inventory_analytics/batch_inventory_report/service.py | 4 +++- inventory_analytics/channel_inventory_sync/entrypoint.py | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/inventory_analytics/batch_inventory_report/service.py b/inventory_analytics/batch_inventory_report/service.py index cebcf0a..06b61f9 100644 --- a/inventory_analytics/batch_inventory_report/service.py +++ b/inventory_analytics/batch_inventory_report/service.py @@ -232,13 +232,15 @@ def log_event(level: int, event: str, **fields: Any) -> None: class PrefectLogHandler(logging.Handler): def emit(self, record: logging.LogRecord) -> None: + if record.name.startswith("prefect"): + return try: from prefect.logging import get_run_logger prefect_logger = get_run_logger() except Exception: return - message = self.format(record) + message = record.getMessage() log_method = getattr(prefect_logger, record.levelname.lower(), None) if log_method is None: log_method = prefect_logger.info diff --git a/inventory_analytics/channel_inventory_sync/entrypoint.py b/inventory_analytics/channel_inventory_sync/entrypoint.py index 9bd6616..06cc1bd 100644 --- a/inventory_analytics/channel_inventory_sync/entrypoint.py +++ b/inventory_analytics/channel_inventory_sync/entrypoint.py @@ -31,13 +31,15 @@ LOG_FIELD_LABELS = { class PrefectLogHandler(logging.Handler): def emit(self, record: logging.LogRecord) -> None: + if record.name.startswith("prefect"): + return try: from prefect.logging import get_run_logger prefect_logger = get_run_logger() except Exception: return - message = self.format(record) + message = record.getMessage() log_method = getattr(prefect_logger, record.levelname.lower(), None) if log_method is None: log_method = prefect_logger.info