Skip to content

Commit 4b22e8c

Browse files
authored
fix(ingestion_consumer): mask before multimodal handling (#1139)
1 parent 0a250d6 commit 4b22e8c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

langfuse/_task_manager/ingestion_consumer.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,9 @@ def _next(self):
115115

116116
continue
117117

118+
# apply mask
119+
self._apply_mask_in_place(event)
120+
118121
# handle multimodal data
119122
self._media_manager.process_media_in_event(event)
120123

@@ -125,9 +128,6 @@ def _next(self):
125128
log_message="<truncated due to size exceeding limit>",
126129
)
127130

128-
# apply mask
129-
self._apply_mask_in_place(event)
130-
131131
# check for serialization errors
132132
try:
133133
json.dumps(event, cls=EventSerializer)

0 commit comments

Comments
 (0)