small improvements in veo handling

app.py

@@ -100,6 +100,23 @@ def format_metadata(provider, status, error=None, duration=None):
     return "\n".join(lines)
 
 
+# Small per-provider status indicator shown next to its checkbox (visible
+# without expanding that provider's accordion) - a CSS spinner while a
+# request is in flight, then a static icon once it settles. The spinner's
+# look is defined by STATUS_SPINNER_CSS, injected once via gr.Blocks(css=...).
+_STATUS_ICONS = {
+    "idle": "",
+    "running": '<span class="ks-spinner" title="Running"></span>',
+    "ok": '<span title="Done" style="font-size:1.1em;">\u2705</span>',
+    "error": '<span title="Error" style="font-size:1.1em;">\u274c</span>',
+    "skipped": '<span title="Skipped" style="font-size:1.1em;">\u23ed\ufe0f</span>',
+}
+
+
+def format_status_icon(status: str) -> str:
+    return _STATUS_ICONS.get(status, "")
+
+
 def format_result_metadata(result: RunResult) -> str:
     lines = [
         f"**{result.provider_name}**",
@@ -178,15 +195,18 @@ def on_submit(image_path, prompt, duration_seconds, resolution, history, *dynami
     selected_names = {provider.name for provider in selected_runtime_providers}
 
     metadata_values = []
+    status_values = []
     for provider in PROVIDERS:
         if provider.name in selected_names:
             metadata_values.append(
                 format_metadata(apply_global_settings(provider, prompt, duration_seconds, resolution), "running")
             )
+            status_values.append(format_status_icon("running"))
         else:
             metadata_values.append(
                 format_metadata(apply_global_settings(provider, prompt, duration_seconds, resolution), "skipped")
             )
+            status_values.append(format_status_icon("skipped"))
             results_by_name[provider.name] = RunResult(
                 provider_name=provider.name,
                 output_path=None,
@@ -196,7 +216,7 @@ def on_submit(image_path, prompt, duration_seconds, resolution, history, *dynami
                 params_used=provider.params,
             )
     video_values = [None] * len(PROVIDERS)
-    yield metadata_values + video_values + [history]
+    yield metadata_values + status_values + video_values + [history]
 
     for provider, video_bytes, error, duration in run_providers(
         selected_runtime_providers, image_path, prompt, duration_seconds, resolution
@@ -214,6 +234,7 @@ def on_submit(image_path, prompt, duration_seconds, resolution, history, *dynami
                 params_used=provider.params,
             )
             metadata_values[index] = format_metadata(provider, "ok", duration=duration)
+            status_values[index] = format_status_icon("ok")
             video_values[index] = output_path
         else:
             results_by_name[provider.name] = RunResult(
@@ -225,9 +246,10 @@ def on_submit(image_path, prompt, duration_seconds, resolution, history, *dynami
                 params_used=provider.params,
             )
             metadata_values[index] = format_metadata(provider, "error", error=str(error), duration=duration)
+            status_values[index] = format_status_icon("error")
             video_values[index] = None
 
-        yield metadata_values + video_values + [history]
+        yield metadata_values + status_values + video_values + [history]
 
     run = Run(
         run_id=run_id,
@@ -239,8 +261,26 @@ def on_submit(image_path, prompt, duration_seconds, resolution, history, *dynami
     save_run(run)
     logger.info("Run %s: saved", run_id)
 
-    yield metadata_values + video_values + [history + [run]]
-
+    yield metadata_values + status_values + video_values + [history + [run]]
+
+
+# CSS for the small per-provider running spinner (see format_status_icon) -
+# a plain rotating-border circle so no extra asset/dependency is needed.
+STATUS_SPINNER_CSS = """
+.ks-spinner {
+    display: inline-block;
+    width: 14px;
+    height: 14px;
+    border: 2px solid var(--border-color-primary, #999);
+    border-top-color: var(--color-accent, #555);
+    border-radius: 50%;
+    animation: ks-spin 0.8s linear infinite;
+    vertical-align: middle;
+}
+@keyframes ks-spin {
+    to { transform: rotate(360deg); }
+}
+"""
 
 with gr.Blocks(title="Kaleidoscope") as demo:
     gr.Markdown(
@@ -297,7 +337,8 @@ with gr.Blocks(title="Kaleidoscope") as demo:
                     )
                 )
 
-    image_input = gr.Image(type="filepath", label="Input image")
+    with gr.Accordion(label="Input image", open=True) as image_accordion:
+        image_input = gr.Image(type="filepath", label="Input image")
     prompt_input = gr.Textbox(
         label="Prompt (optional)",
         placeholder="Used by providers that support a prompt; ignored by the rest.",
@@ -307,17 +348,20 @@ with gr.Blocks(title="Kaleidoscope") as demo:
     gr.Markdown("## Results")
     check_all_btn = gr.Button("Check all models")
     enabled_components = []
+    status_components = []
     metadata_components = []
     video_components = []
     for provider in PROVIDERS:
         with gr.Row():
-            enabled_components.append(gr.Checkbox(label="Use", value=True))
+            with gr.Column(scale=0, min_width=90):
+                enabled_components.append(gr.Checkbox(label="Use", value=True))
+                status_components.append(gr.HTML(value=format_status_icon("idle")))
             with gr.Accordion(label=provider.name, open=False):
                 with gr.Row():
                     with gr.Column(scale=1):
                         metadata_components.append(gr.Markdown(format_metadata(provider, "idle")))
                     with gr.Column(scale=2):
-                        video_components.append(gr.Video(label=provider.name))
+                        video_components.append(gr.Video(label=provider.name, interactive=False))
 
     gr.Markdown("## Past runs")
     # Start empty and populate via demo.load() below, so every new page
@@ -382,15 +426,23 @@ with gr.Blocks(title="Kaleidoscope") as demo:
                         with gr.Column(scale=1):
                             gr.Markdown(format_result_metadata(result))
                         with gr.Column(scale=2):
-                            gr.Video(value=result.output_path)
+                            gr.Video(value=result.output_path, interactive=False)
 
     submit_btn.click(
-        on_submit,
+        fn=lambda: (gr.update(interactive=False), gr.update(open=False)),
+        inputs=None,
+        outputs=[submit_btn, image_accordion],
+    ).then(
+        fn=on_submit,
         inputs=[image_input, prompt_input, duration_input, resolution_input, history_state]
         + token_inputs
         + extra_config_inputs
         + enabled_components,
-        outputs=metadata_components + video_components + [history_state],
+        outputs=metadata_components + status_components + video_components + [history_state],
+    ).then(
+        fn=lambda: gr.update(interactive=True),
+        inputs=None,
+        outputs=submit_btn,
     )
 
 demo.queue()
@@ -400,4 +452,4 @@ if __name__ == "__main__":
     # /data (on a Hugging Face Space) lives outside the cwd and the system
     # temp dir, so Gradio refuses to serve run files from it unless the
     # directory is explicitly allow-listed here.
-    demo.launch(allowed_paths=[get_data_dir()])
+    demo.launch(allowed_paths=[get_data_dir()], css=STATUS_SPINNER_CSS)

providers.py

@@ -12,6 +12,7 @@ from __future__ import annotations
 
 import base64
 import io
+import json
 import logging
 import mimetypes
 import time
@@ -501,6 +502,28 @@ def _extract_veo_video_uri(node) -> str | None:
     return None
 
 
+def _extract_veo_filter_reason(node) -> str | None:
+    """Recursively searches a Gemini API operation response for a
+    safety-filter rejection reason (e.g. `raiMediaFilteredReasons`), which
+    is the most common real-world cause of a "done" operation with no
+    video URI - the prompt/image got silently filtered rather than the
+    response shape being unexpected."""
+    if isinstance(node, dict):
+        reasons = node.get("raiMediaFilteredReasons")
+        if reasons:
+            return "; ".join(str(reason) for reason in reasons)
+        for value in node.values():
+            found = _extract_veo_filter_reason(value)
+            if found:
+                return found
+    elif isinstance(node, list):
+        for item in node:
+            found = _extract_veo_filter_reason(item)
+            if found:
+                return found
+    return None
+
+
 def veo_call(
     provider: ModelProvider,
     image_path: str,
@@ -565,6 +588,21 @@ def veo_call(
 
     video_uri = _extract_veo_video_uri(operation.get("response"))
     if not video_uri:
+        # Log the full response so this is actually debuggable next time -
+        # the shape of a "done" operation with no video can vary (safety
+        # filtering, quota/partial failures, an undocumented response
+        # nesting, etc.) and a bare exception message throws that
+        # information away.
+        logger.error(
+            "veo %s: operation done but no video URI found; full response=%s",
+            provider.name,
+            json.dumps(operation, indent=2)[:4000],
+        )
+        filter_reason = _extract_veo_filter_reason(operation.get("response"))
+        if filter_reason:
+            raise RuntimeError(
+                f"veo operation for '{provider.name}' was rejected by Google's safety filters: {filter_reason}"
+            )
         raise RuntimeError(f"veo operation for '{provider.name}' succeeded but returned no video URI")
 
     video_response = requests.get(video_uri, headers=headers, timeout=180)