deploy live demo

migrations/009_gen_note.sql

@@ -0,0 +1,6 @@
+-- 009_gen_note.sql — a transient, human-readable generation status note surfaced
+-- live in the approval UI (e.g. "Veo blockade klippet — byter seed (försök 2/3)…").
+-- Cleared at the start of each generation and when a segment finally succeeds. It is
+-- NOT a creative attribute and never feeds the strategist (kept out of videos.tags).
+
+alter table videos add column if not exists gen_note text;

pipeline/flow.py

@@ -136,7 +136,7 @@ def generate_pending(video_id: str, kinds: tuple[str, ...] | None = None,
         raise RuntimeError(f"video {video_id} has no segments to generate")
 
     generated: list[str] = []
-    db.execute("update videos set status = 'generating', error = null where id = %s", (video_id,))
+    db.execute("update videos set status = 'generating', error = null, gen_note = null where id = %s", (video_id,))
     for seg in rows:
         done = (seg["file_path"] and seg["status"] != "qc_fail"
                 and (storage.is_remote(seg["file_path"]) or Path(seg["file_path"]).exists()))

pipeline/veo.py

@@ -361,12 +361,22 @@ def _rephrase_segment_line(segment_id: str) -> str | None:
     return new_text
 
 
+def _set_gen_note(segment_id: str, note: str | None) -> None:
+    """Surface a transient generation status to the UI (e.g. RAI seed-swap progress).
+    Stored on videos.gen_note — not a creative attribute, never in videos.tags."""
+    db.execute(
+        "update videos set gen_note = %s where id = (select video_id from segments where id = %s)",
+        (note, str(segment_id)),
+    )
+
+
 def _handle_safety_block(segment_id: str, first_exc: VeoSafetyBlock) -> str:
     """On a Veo safety block (§12.5): Veo's RAI filter is non-deterministic and usually
     trips on the rendered VIDEO, not the words — so we retry on a **fresh seed** (the words
     and startframe stay identical), looping up to VEO_RAI_MAX_RETRIES times. A new seed
-    almost always escapes the false positive. Still blocked after that → surface; the UI
-    'Försök igen' button restarts a fresh loop."""
+    almost always escapes the false positive. The retry runs **automatically**; its progress
+    is surfaced live via videos.gen_note. Only when the loop is exhausted does it surface as
+    failed — and only then does the UI show a 'Försök igen' button."""
     s = get_settings()
     if not s.veo_rai_autoretry:
         raise first_exc
@@ -374,6 +384,8 @@ def _handle_safety_block(segment_id: str, first_exc: VeoSafetyBlock) -> str:
     for attempt in range(1, max(1, s.veo_rai_max_retries) + 1):
         new_seed = duration.random_seed()
         db.execute("update segments set seed = %s where id = %s", (new_seed, segment_id))
+        _set_gen_note(segment_id,
+                      f"Veo blockade klippet — byter seed (försök {attempt}/{s.veo_rai_max_retries})…")
         print(f"[RAI] segment {segment_id}: safety block — auto-retry {attempt}/{s.veo_rai_max_retries} "
               f"on a fresh seed {new_seed} (same words + startframe).")
         op_name = generate_segment(segment_id)
@@ -383,7 +395,7 @@ def _handle_safety_block(segment_id: str, first_exc: VeoSafetyBlock) -> str:
             last_exc = e2
             continue
     print(f"[RAI] segment {segment_id}: still blocked after {s.veo_rai_max_retries} fresh seeds — surfacing "
-          f"(click 'Försök igen' to start a fresh {s.veo_rai_max_retries}-retry loop).")
+          f"(the UI now shows 'Försök igen' for a fresh {s.veo_rai_max_retries}-retry loop).")
     raise last_exc
 
 
@@ -410,4 +422,5 @@ def generate_and_download(segment_id: str) -> str:
         path = _handle_safety_block(segment_id, exc)
     file_path = _maybe_upload_clip(segment_id, path)
     db.execute("update segments set file_path = %s where id = %s", (file_path, segment_id))
+    _set_gen_note(segment_id, None)   # clear any RAI seed-swap note — this segment is done
     return file_path

pipeline/webapp/app.py

@@ -185,7 +185,7 @@ def _video_view(video_id: str) -> dict[str, Any] | None:
 def _set_failed(video_id: str, exc: Exception) -> None:
     msg = f"{type(exc).__name__}: {exc}"
     try:
-        db.execute("update videos set status = 'failed', error = %s where id = %s",
+        db.execute("update videos set status = 'failed', error = %s, gen_note = null where id = %s",
                    (msg[:2000], video_id))
     except Exception:
         pass
@@ -353,7 +353,8 @@ def video_status(video_id: str):
     v = view["video"]
     return JSONResponse({
         "id": video_id, "stage": view["stage"], "status": v["status"], "seed": v["seed"],
-        "error": v.get("error"), "inflight": view["inflight"], "final_url": view["final_url"],
+        "error": v.get("error"), "gen_note": v.get("gen_note"),
+        "inflight": view["inflight"], "final_url": view["final_url"],
         "progress": view["progress"],
         "segments": [
             {"idx": s["idx"], "take": s["take"], "kind": s["kind"],

pipeline/webapp/templates/video.html

@@ -52,6 +52,7 @@
     <form method="post" action="/videos/{{ video.id }}/generate-hooks"><button class="btn">Generera hook-tagningar</button></form>
   {% elif stage == "generating_hooks" %}
     <p class="muted" style="margin-top:12px">Genererar {{ hooks|length }} tagningar… sidan uppdaterar sig själv.</p>
+    {% if video.gen_note %}<p class="pill warn" style="margin-top:10px;display:inline-block">⟳ {{ video.gen_note }}</p>{% endif %}
   {% elif stage == "pick_seed" %}
     <p class="muted" style="margin-top:12px">Samma replik, två seeds. Välj den där avataren ser bäst ut — den låses för hela videon.</p>
     <div class="pickgrid">
@@ -79,6 +80,7 @@
     <form method="post" action="/videos/{{ video.id }}/finish" style="margin-top:12px"><button class="btn">Generera resten & klipp ihop</button></form>
   {% elif stage in ("generating_body","assembling") %}
     <p class="muted" style="margin-top:12px">{{ progress.done }}/{{ progress.total }} klipp klara. Sidan uppdaterar sig själv.</p>
+    {% if video.gen_note %}<p class="pill warn" style="margin-top:10px;display:inline-block">⟳ {{ video.gen_note }}</p>{% endif %}
   {% elif stage == "need_assemble" %}
     <form method="post" action="/videos/{{ video.id }}/assemble" style="margin-top:12px"><button class="btn">Klipp ihop videon</button></form>
   {% elif stage == "done" %}
@@ -119,11 +121,11 @@
 </div>
 
 <script>
-  const STAGE={{ stage|tojson }}, VID={{ video.id|tojson }}, DONE={{ progress.done }};
+  const STAGE={{ stage|tojson }}, VID={{ video.id|tojson }}, DONE={{ progress.done }}, NOTE={{ (video.gen_note or '')|tojson }};
   if(["generating_hooks","generating_body","assembling"].includes(STAGE)){
     setInterval(async()=>{try{const d=await(await fetch(`/videos/${VID}/status`)).json();
-      // reload on a stage change OR when another clip finishes (live progress)
-      if(d.stage!==STAGE || (d.progress && d.progress.done!==DONE)) location.reload();
+      // reload on stage change, a finished clip, or a new retry note (live seed-swap status)
+      if(d.stage!==STAGE || (d.progress && d.progress.done!==DONE) || ((d.gen_note||'')!==NOTE)) location.reload();
     }catch(e){}},2000);
   }
 </script>