diff --git a/tests/integration/test_tts_api.py b/tests/integration/test_tts_api.py index 09cf1171b..69d6e5587 100644 --- a/tests/integration/test_tts_api.py +++ b/tests/integration/test_tts_api.py @@ -865,10 +865,12 @@ class TestTTSLifecycle: # 模拟 worker 完成 job = tts_repo.get(job_id) assert job is not None - # 如果任务因 Celery 调度失败而处于 failed 状态,先重置为 pending + # 根据当前状态决定下一步:failed 先重置,pending 则转 processing,已是 processing 则跳过 if job.status == TTSJobStatus.FAILED: job.prepare_retry() - job.mark_processing() + job.mark_processing() + elif job.status == TTSJobStatus.PENDING: + job.mark_processing() job.mark_completed( output_audio_url="https://cdn.example.com/tts/final.mp3", duration=8.0,