Update process_interview.py

process_interview.py

@@ -177,16 +177,31 @@ def extract_prosodic_features(audio_path: str, start_ms: int, end_ms: int) -> Di
         }
 
 
+import requests
+import time
+import logging
+from typing import Dict
+
+logger = logging.getLogger(__name__)
+
 def transcribe(audio_path: str) -> Dict:
     try:
+        # 1. رفع الملف
         with open(audio_path, 'rb') as f:
             upload_response = requests.post(
                 "https://api.assemblyai.com/v2/upload",
                 headers={"authorization": ASSEMBLYAI_KEY},
                 data=f
             )
-        audio_url = upload_response.json()['upload_url']
+        
+        if upload_response.status_code != 200:
+            raise Exception(f"فشل رفع الملف: {upload_response.status_code} - {upload_response.text}")
+        
+        audio_url = upload_response.json().get('upload_url')
+        if not audio_url:
+            raise Exception(f"لم يتم الحصول على رابط الملف: {upload_response.json()}")
 
+        # 2. بدء التحويل (Transcription)
         transcript_response = requests.post(
             "https://api.assemblyai.com/v2/transcript",
             headers={"authorization": ASSEMBLYAI_KEY},
@@ -196,25 +211,38 @@ def transcribe(audio_path: str) -> Dict:
                 "filter_profanity": True
             }
         )
-        transcript_id = transcript_response.json()['id']
 
+        if transcript_response.status_code != 200:
+            raise Exception(f"فشل طلب التحويل: {transcript_response.status_code} - {transcript_response.text}")
+        
+        resp_json = transcript_response.json()
+        transcript_id = resp_json.get('id')
+        
+        if not transcript_id:
+            raise Exception(f"AssemblyAI لم ترجع ID. الرد كان: {resp_json}")
+
+        # 3. متابعة الحالة
         while True:
-            result = requests.get(
+            result_response = requests.get(
                 f"https://api.assemblyai.com/v2/transcript/{transcript_id}",
                 headers={"authorization": ASSEMBLYAI_KEY}
-            ).json()
-
+            )
+            
+            if result_response.status_code != 200:
+                raise Exception(f"خطأ أثناء جلب النتيجة: {result_response.status_code} - {result_response.text}")
+                
+            result = result_response.json()
+            
             if result['status'] == 'completed':
                 return result
             elif result['status'] == 'error':
-                raise Exception(result['error'])
+                raise Exception(f"خطأ من الخدمة: {result.get('error', 'غير معروف')}")
 
             time.sleep(5)
+
     except Exception as e:
         logger.error(f"Transcription failed: {str(e)}")
-        raise
-
-
+        raise e
 def process_utterance(utterance, full_audio, wav_file):
     try:
         start = utterance['start']