import sys
import os

# Add backend/src to path
sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '../../')))

from src.services.clustering_service import ClusteringService

def test_clustering_pipeline():
    print("🚀 Starting Clustering Pipeline Test...")
    service = ClusteringService()
    
    try:
        # Run clustering with 5 clusters for more granular grouping
        service.run_clustering_pipeline(n_clusters=5)
        print("✅ Pipeline test completed successfully.")
    except Exception as e:
        print(f"❌ Pipeline test failed: {e}")

if __name__ == "__main__":
    test_clustering_pipeline()