diff --git a/examples/filters/langfuse_filter_pipeline.py b/examples/filters/langfuse_filter_pipeline.py
index 8576ef2f..a7529857 100644
--- a/examples/filters/langfuse_filter_pipeline.py
+++ b/examples/filters/langfuse_filter_pipeline.py
@@ -110,6 +110,7 @@ async def inlet(self, body: dict, user: Optional[dict] = None) -> dict:
         self.chat_generations[body["chat_id"]] = generation
         print(trace.get_trace_url())
 
+        del body["chat_id"]
         return body
 
     async def outlet(self, body: dict, user: Optional[dict] = None) -> dict: