We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 840e73a commit bf9d33aCopy full SHA for bf9d33a
1 file changed
langfuse/_task_manager/ingestion_consumer.py
@@ -115,6 +115,9 @@ def _next(self):
115
116
continue
117
118
+ # apply mask
119
+ self._apply_mask_in_place(event)
120
+
121
# handle multimodal data
122
self._media_manager.process_media_in_event(event)
123
@@ -125,9 +128,6 @@ def _next(self):
125
128
log_message="<truncated due to size exceeding limit>",
126
129
)
127
130
- # apply mask
- self._apply_mask_in_place(event)
-
131
# check for serialization errors
132
try:
133
json.dumps(event, cls=EventSerializer)
0 commit comments