feat(multimodal): 完成阶段F运行管理与收尾验收

2026-09-05 02:02:45 +08:00
parent f2c75f921e
commit d5eff47417
29 changed files with 1045 additions and 86 deletions
@@ -134,6 +134,10 @@ async def _execute(job_id, request, routing=None):
    from app.contracts import TranscriptSegment
    token = runtime_context.set(RuntimeConfig.model_validate(job.model_snapshot.get("local_runtime", {})))
    def progress(message):
+        if message.get("reset"):
+            job.segments = []; job.progress = 0
+            save(job, "AttemptRestarted")
+            return
        job.progress = max(0.0, min(0.99, message["progress"]))
        job.segments.append(TranscriptSegment.model_validate(message["segment"]))
        save(job, "SegmentReady")