Update langgraph_nodes.py

langgraph_nodes.py

@@ -375,12 +375,6 @@ def stage1_classification_node(state: ReviewState) -> Dict[str, Any]:
     stage1_time = time.time() - start_time
     print(f"      ✅ Stage 1 complete ({stage1_time:.2f}s)")
     
-    # Save to database
-    db = EnhancedDatabase()
-    db.connect()
-    db.save_stage1_results(state['review_id'], llm1_result, llm2_result, manager_result)
-    db.close()
-    
     return {
         "llm1_result": llm1_result,
         "llm2_result": llm2_result,
@@ -534,12 +528,6 @@ def stage2_sentiment_node(state: ReviewState) -> Dict[str, Any]:
     stage2_time = time.time() - start_time
     print(f"      ✅ Stage 2 complete ({stage2_time:.2f}s)")
     
-    # Save to database
-    db = EnhancedDatabase()
-    db.connect()
-    db.save_stage2_results(state['review_id'], best_result, alt_result, layer_result)
-    db.close()
-    
     return {
         "best_sentiment_result": best_result,
         "alt_sentiment_result": alt_result,
@@ -690,12 +678,6 @@ Respond ONLY in valid JSON format:
     # Calculate total time
     total_time = state.get('stage1_time', 0) + state.get('stage2_time', 0) + stage3_time
     
-    # Save to database
-    db = EnhancedDatabase()
-    db.connect()
-    db.save_stage3_results(state['review_id'], result)
-    db.close()
-    
     return {
         "final_result": result,
         "final_sentiment": result['final_sentiment'],