Revert httpx.Client customization: use default OpenAI SDK settings for async compatibility in HF Spaces

main.py

@@ -3,7 +3,6 @@ import sys
 import json
 import time
 import boto3
-import httpx
 from pathlib import Path
 from typing import Dict, List, Optional, Tuple, Any
 from anthropic import Anthropic
@@ -252,20 +251,13 @@ class LLMAnalyzer:
         if provider == ModelProvider.OPENAI:
             if not OPENAI_API_KEY:
                 raise ValueError(f"OpenAI API key not configured. Please set OPENAI_API_KEY environment variable to use {provider.value} provider.")
-            self.client = openai.OpenAI(
-                api_key=OPENAI_API_KEY, 
-                timeout=120.0,
-                http_client=httpx.Client(http2=False, timeout=120.0)
-            )
+            # Use default httpx settings for better compatibility with async environments
+            self.client = openai.OpenAI(api_key=OPENAI_API_KEY, timeout=120.0)
         elif provider == ModelProvider.DEEPSEEK:
             if not DEEPSEEK_API_KEY:
                 raise ValueError(f"DeepSeek API key not configured. Please set DEEPSEEK_API_KEY environment variable to use {provider.value} provider.")
-            self.client = openai.OpenAI(
-                api_key=DEEPSEEK_API_KEY, 
-                base_url="https://api.deepseek.com", 
-                timeout=120.0,
-                http_client=httpx.Client(http2=False, timeout=120.0)
-            )
+            # Use default httpx settings for better compatibility with async environments
+            self.client = openai.OpenAI(api_key=DEEPSEEK_API_KEY, base_url="https://api.deepseek.com", timeout=120.0)
         elif provider == ModelProvider.ANTHROPIC:
             if not ANTHROPIC_API_KEY:
                 raise ValueError(f"Anthropic API key not configured. Please set ANTHROPIC_API_KEY environment variable to use {provider.value} provider.")
@@ -662,13 +654,8 @@ def generate_legal_position(
             raise Exception(f"Текст судового рішення занадто короткий або відсутній (довжина: {len(court_decision_text) if court_decision_text else 0} символів). Будь ласка, перевірте вхідні дані.")
 
         if provider == ModelProvider.OPENAI.value:
-            # Increase timeout for complex models and HF Spaces environment
-            # Use specific http_client with HTTP/2 disabled to resolve Connection Errors in some environments
-            client = OpenAI(
-                api_key=OPENAI_API_KEY, 
-                timeout=120.0,
-                http_client=httpx.Client(http2=False, timeout=120.0)
-            )
+            # Use default OpenAI client settings for async compatibility in HF Spaces
+            client = OpenAI(api_key=OPENAI_API_KEY, timeout=120.0)
             
             # Retry logic for connection errors
             max_retries = 3
@@ -744,14 +731,8 @@ def generate_legal_position(
                 }
 
         if provider == ModelProvider.DEEPSEEK.value:
-            # Increase timeout and improve reliability for DeepSeek API 
-            # Use specific http_client with HTTP/2 disabled to resolve Connection Errors
-            client = OpenAI(
-                api_key=DEEPSEEK_API_KEY, 
-                base_url="https://api.deepseek.com", 
-                timeout=120.0,
-                http_client=httpx.Client(http2=False, timeout=120.0)
-            )
+            # Use default client settings for async compatibility in HF Spaces
+            client = OpenAI(api_key=DEEPSEEK_API_KEY, base_url="https://api.deepseek.com", timeout=120.0)
             
             # Retry logic for DeepSeek
             max_retries = 3

test_api_connection.py

@@ -0,0 +1,151 @@
+#!/usr/bin/env python3
+"""
+Test script to verify API connections for OpenAI and DeepSeek
+"""
+import os
+import httpx
+from dotenv import load_dotenv
+from openai import OpenAI
+
+# Load environment variables
+load_dotenv()
+
+def test_openai():
+    """Test OpenAI API connection"""
+    print("\n" + "="*60)
+    print("Testing OpenAI API Connection")
+    print("="*60)
+    
+    api_key = os.getenv("OPENAI_API_KEY")
+    if not api_key:
+        print("❌ OPENAI_API_KEY not found in environment")
+        return False
+    
+    print(f"✓ API Key found (length: {len(api_key)})")
+    
+    try:
+        # Test with HTTP/2 enabled (default)
+        print("\n[Test 1] Using default settings (HTTP/2 enabled)...")
+        client = OpenAI(api_key=api_key, timeout=30.0)
+        response = client.chat.completions.create(
+            model="gpt-4o-mini",
+            messages=[{"role": "user", "content": "Say 'connection test passed'"}],
+            max_tokens=10
+        )
+        print(f"✅ Success with HTTP/2: {response.choices[0].message.content}")
+    except Exception as e:
+        print(f"❌ Failed with HTTP/2: {type(e).__name__}: {str(e)}")
+    
+    try:
+        # Test with HTTP/2 disabled
+        print("\n[Test 2] Using HTTP/1.1 (HTTP/2 disabled)...")
+        client = OpenAI(
+            api_key=api_key, 
+            timeout=30.0,
+            http_client=httpx.Client(http2=False, timeout=30.0)
+        )
+        response = client.chat.completions.create(
+            model="gpt-4o-mini",
+            messages=[{"role": "user", "content": "Say 'connection test passed'"}],
+            max_tokens=10
+        )
+        print(f"✅ Success with HTTP/1.1: {response.choices[0].message.content}")
+        return True
+    except Exception as e:
+        print(f"❌ Failed with HTTP/1.1: {type(e).__name__}: {str(e)}")
+        return False
+
+
+def test_deepseek():
+    """Test DeepSeek API connection"""
+    print("\n" + "="*60)
+    print("Testing DeepSeek API Connection")
+    print("="*60)
+    
+    api_key = os.getenv("DEEPSEEK_API_KEY")
+    if not api_key:
+        print("❌ DEEPSEEK_API_KEY not found in environment")
+        return False
+    
+    print(f"✓ API Key found (length: {len(api_key)})")
+    
+    try:
+        # Test with HTTP/2 enabled (default)
+        print("\n[Test 1] Using default settings (HTTP/2 enabled)...")
+        client = OpenAI(
+            api_key=api_key, 
+            base_url="https://api.deepseek.com",
+            timeout=30.0
+        )
+        response = client.chat.completions.create(
+            model="deepseek-chat",
+            messages=[{"role": "user", "content": "Say 'connection test passed'"}],
+            max_tokens=10
+        )
+        print(f"✅ Success with HTTP/2: {response.choices[0].message.content}")
+    except Exception as e:
+        print(f"❌ Failed with HTTP/2: {type(e).__name__}: {str(e)}")
+    
+    try:
+        # Test with HTTP/2 disabled
+        print("\n[Test 2] Using HTTP/1.1 (HTTP/2 disabled)...")
+        client = OpenAI(
+            api_key=api_key, 
+            base_url="https://api.deepseek.com",
+            timeout=30.0,
+            http_client=httpx.Client(http2=False, timeout=30.0)
+        )
+        response = client.chat.completions.create(
+            model="deepseek-chat",
+            messages=[{"role": "user", "content": "Say 'connection test passed'"}],
+            max_tokens=10
+        )
+        print(f"✅ Success with HTTP/1.1: {response.choices[0].message.content}")
+        return True
+    except Exception as e:
+        print(f"❌ Failed with HTTP/1.1: {type(e).__name__}: {str(e)}")
+        return False
+
+
+def test_network_connectivity():
+    """Test basic network connectivity"""
+    print("\n" + "="*60)
+    print("Testing Network Connectivity")
+    print("="*60)
+    
+    urls = [
+        "https://api.openai.com",
+        "https://api.deepseek.com",
+        "https://api.anthropic.com",
+        "https://generativelanguage.googleapis.com"
+    ]
+    
+    for url in urls:
+        try:
+            client = httpx.Client(timeout=10.0)
+            response = client.get(url)
+            print(f"✅ {url}: HTTP {response.status_code}")
+        except Exception as e:
+            print(f"❌ {url}: {type(e).__name__}: {str(e)}")
+
+
+if __name__ == "__main__":
+    print("\n🔍 API Connection Test Suite")
+    print("="*60)
+    
+    # Test network connectivity first
+    test_network_connectivity()
+    
+    # Test OpenAI
+    openai_ok = test_openai()
+    
+    # Test DeepSeek
+    deepseek_ok = test_deepseek()
+    
+    # Summary
+    print("\n" + "="*60)
+    print("Summary")
+    print("="*60)
+    print(f"OpenAI:  {'✅ OK' if openai_ok else '❌ FAILED'}")
+    print(f"DeepSeek: {'✅ OK' if deepseek_ok else '❌ FAILED'}")
+    print("="*60)