gahusb/ai-trade
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(music-render): drop secondary webhook_add_track (T5 follow-up)

Browse Source 
Code review found: f"{task_id}_v2" / "_inst" synthetic task IDs never
exist in NAS music_tasks table -> webhook returns 404 -> silent fail.

NAS music-lab/main.py._sync_library_with_disk() auto-registers any
.mp3 in the disk that has no DB row on next GET /api/music/library.
So Windows worker just writes the file to SMB; NAS picks it up on
the next library fetch -- matches NAS source behavior at file level.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
gahusb
2026-05-19 04:53:27 +09:00
parent 4e72f8ca2e
commit a5274a4fa7
1 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
services/music-render/providers/suno.py
View File

@@ -250,11 +250,9 @@ def run_suno_generation(task_id: str, params: dict) -> None:
if len(completed) > 1: if len(completed) > 1:
try: try:
second = _download_and_register(f"{task_id}_v2", completed[1], params) # 보조 변형은 SMB에 파일만 저장. NAS _sync_library_with_disk가 다음
if second: # GET /api/music/library 호출 시 자동으로 라이브러리에 등록.
# 두 번째 변형은 별도 task가 아니라 별도 track으로만 등록 _download_and_register(f"{task_id}_v2", completed[1], params)
webhook_add_track(f"{task_id}_v2", "succeeded", 100, "두 번째 변형",
audio_url=second["audio_url"], track=second)
except Exception: except Exception:
pass pass
@@ -348,10 +346,8 @@ def run_vocal_removal(task_id: str, params: dict) -> None:
track = _download_and_register(task_id, completed[0], vp) track = _download_and_register(task_id, completed[0], vp)
if len(completed) > 1: if len(completed) > 1:
ip = {**params, "title": f"{params.get('title', 'Track')} (Instrumental)"} ip = {**params, "title": f"{params.get('title', 'Track')} (Instrumental)"}
second = _download_and_register(f"{task_id}_inst", completed[1], ip) # Instrumental 변형은 SMB에 파일만 저장. NAS _sync_library_with_disk가 자동 등록.
if second: _download_and_register(f"{task_id}_inst", completed[1], ip)
webhook_add_track(f"{task_id}_inst", "succeeded", 100, "Instrumental",
audio_url=second["audio_url"], track=second)
if track: if track:
webhook_add_track(task_id, "succeeded", 100, "보컬 분리 완료", webhook_add_track(task_id, "succeeded", 100, "보컬 분리 완료",
audio_url=track["audio_url"], track=track) audio_url=track["audio_url"], track=track)