Update app.py

Removed thinking tags removal

app.py

@@ -165,14 +165,6 @@ class WebContentFetcher:
             results.append(result)
             time.sleep(1)  # Be respectful to servers
         return results
-        
-def remove_thinking_tags(text):
-    import re
-    # Remove <think>...</think> blocks
-    cleaned = re.sub(r'<think>.*?</think>', '', text, flags=re.DOTALL)
-    # Remove thinking markers
-    cleaned = re.sub(r'<thinking>.*?</thinking>', '', cleaned, flags=re.DOTALL)
-    return cleaned.strip()
     
 # --- File Download Utility ---
 def download_attachment(url: str, temp_dir: str) -> Optional[str]:
@@ -374,7 +366,7 @@ class IntelligentAgent:
                     max_tokens=max_tokens,
                     temperature=temperature
                 )
-                return remove_thinking_tags(response.choices[0].message.content.strip())
+                return response.choices[0].message.content.strip()
             except Exception as chat_error:
                 if self.debug:
                     print(f"Chat completion failed: {chat_error}, trying text generation...")
@@ -386,7 +378,6 @@ class IntelligentAgent:
                     temperature=temperature,
                     do_sample=temperature > 0
                 )
-                response = remove_thinking_tags(response.strip)
                 return response.strip()
                 
         except Exception as e:
@@ -655,7 +646,6 @@ Answer:"""
 
         try:
             response = self._chat_completion(answer_prompt, max_tokens=500, temperature=0.3)
-            response = remove_thinking_tags(response)
             return response
             
         except Exception as e:
@@ -729,7 +719,6 @@ Answer:"""
 
             try:
                 response = self._chat_completion(answer_prompt, max_tokens=600, temperature=0.3)
-                response = remove_thinking_tags(response)
                 return response
                 
             except Exception as e:
@@ -780,15 +769,12 @@ Answer:"""
                 if self.debug:
                     print("Using search-based approach")
                 answer = self._answer_with_search(question_text, attachment_context)
-                answer = remove_thinking_tags(answer)
             else:
                 if self.debug:
                     print("Using LLM-only approach")
                 answer = self._answer_with_llm(question_text, attachment_context)
                 print("here")
                 print(answer)
-                answer = remove_thinking_tags(answer)
-                print(answer)
             # Cleanup temporary files
             if image_files or audio_files or code_files:
                 try:
@@ -806,7 +792,6 @@ Answer:"""
 
         if self.debug:
             print(f"Agent returning answer: {answer[:100]}...")
-        answer = remove_thinking_tags(answer)
         return answer
 
     def __call__(self, question: str, image_files: List[str] = None, audio_files: List[str] = None) -> str:
@@ -834,18 +819,15 @@ Answer:"""
                 if self.debug:
                     print("Using search-based approach")
                 answer = self._answer_with_search(question, attachment_context)
-                answer = remove_thinking_tags(answer)
             else:
                 if self.debug:
                     print("Using LLM-only approach")
                 answer = self._answer_with_llm(question, attachment_context)
-                answer = remove_thinking_tags(answer)
         except Exception as e:
             answer = f"Sorry, I encountered an error: {e}"
 
         if self.debug:
             print(f"Agent returning answer: {answer[:100]}...")
-        answer = remove_thinking_tags(answer)
         return answer
 
 def fetch_questions() -> Tuple[str, Optional[pd.DataFrame]]:
@@ -943,7 +925,6 @@ def generate_answers_async(model_name: str = "meta-llama/Llama-3.1-8B-Instruct",
             try:
                 # Use the new method that handles attachments
                 answer = agent.process_question_with_attachments(question_data)
-                answer = remove_thinking_tags(answer)
                 cached_answers[task_id] = {
                     "question": question_text,
                     "answer": answer