test me: is this needed

Author: jhrozek

src/codegate/pipeline/output.py

@@ -160,6 +160,9 @@ async def process_stream(
             logger.error(f"Error processing stream: {e}")
             raise e
         finally:
+            if cleanup_sensitive == False:
+                return
+
             # Process any remaining content in buffer when stream ends
             if self._context.buffer:
                 final_content = "".join(self._context.buffer)
@@ -179,6 +182,7 @@ async def process_stream(
                     model=self._buffered_chunk.model,
                     object="chat.completion.chunk",
                 )
+                logger.error("Clearing buffer in finally")
                 self._context.buffer.clear()
 
             # Cleanup sensitive data through the input context