From bf9d33a3954d02786fca81dc1ab012795af9179c Mon Sep 17 00:00:00 2001 From: Hassieb Pakzad <68423100+hassiebp@users.noreply.github.com> Date: Thu, 13 Mar 2025 10:56:58 +0100 Subject: [PATCH] fix(ingestion_consumer): mask before multimodal handling --- langfuse/_task_manager/ingestion_consumer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/langfuse/_task_manager/ingestion_consumer.py b/langfuse/_task_manager/ingestion_consumer.py index 9900654c2..16d426de0 100644 --- a/langfuse/_task_manager/ingestion_consumer.py +++ b/langfuse/_task_manager/ingestion_consumer.py @@ -115,6 +115,9 @@ def _next(self): continue + # apply mask + self._apply_mask_in_place(event) + # handle multimodal data self._media_manager.process_media_in_event(event) @@ -125,9 +128,6 @@ def _next(self): log_message="", ) - # apply mask - self._apply_mask_in_place(event) - # check for serialization errors try: json.dumps(event, cls=EventSerializer)