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