update transcribe job fix bug

app/jobs/transcribe_job.py

@@ -1,7 +1,6 @@
 import asyncio
 import tempfile
 import os
-from xmlrpc import client
 import requests
 
 from app.core.asr_engine import load_model, transcribe_file, transcribe_file_chunks
@@ -22,10 +21,10 @@ def download_audio(audio_url: str) -> str:
 
 def transcribe_job(audio_url: str, note_id: str, user_id: str | None = None):
     model = load_model()
-
     wav_path = None
+
     try:
-        # 1️⃣ Worker tự fetch audio
+        # 1️⃣ Download audio
         wav_path = download_audio(audio_url)
 
         # 2️⃣ ASR
@@ -59,17 +58,13 @@ def transcribe_job(audio_url: str, note_id: str, user_id: str | None = None):
                 },
                 "client": {"user_id": user_id},
             },
+            # 🔥 trigger enrich pipeline
             "generate": ["normalize", "keywords", "summary", "mindmap"],
         }
 
         client = NoteServiceClient()
-        asyncio.run(client.update_note(note_id, {
-            "status": note_status,
-            "raw_text": text,
-            "metadata": payload["metadata"],
-        }))
-        
+        asyncio.run(client.create_audio_note(payload))
+
     finally:
-        # 3️⃣ Cleanup
         if wav_path and os.path.exists(wav_path):
             os.remove(wav_path)