diff --git a/examples/filters/langfuse_v3_filter_pipeline.py b/examples/filters/langfuse_v3_filter_pipeline.py
index a046eeea..6bc858dc 100644
--- a/examples/filters/langfuse_v3_filter_pipeline.py
+++ b/examples/filters/langfuse_v3_filter_pipeline.py
@@ -391,6 +391,8 @@ async def outlet(self, body: dict, user: Optional[dict] = None) -> dict:
                 generation.update(usage=usage)
 
             generation.end()
+            trace.end()
+            
             self.log(f"LLM generation completed for chat_id: {chat_id}")
         except Exception as e:
             self.log(f"Failed to create LLM generation: {e}")