Upload app.py

app.py

@@ -4308,6 +4308,19 @@ def _condition_key(session,prompt,references,canvas,frames,rewrite,reference_res
                                     ensure_ascii=False).encode()).hexdigest()
 
 
+def _conditioner_error_detail(error):
+    """Keep upstream diagnostics useful without exposing credentials or signed links."""
+    detail=str(getattr(error,'message',None) or str(error) or 'No error details were returned.')
+    for name,value in os.environ.items():
+        if value and len(value)>=8 and any(word in name.upper() for word in ('TOKEN','SECRET','PASSWORD','API_KEY')):
+            detail=detail.replace(value,'[redacted]')
+    detail=re.sub(r'hf_[A-Za-z0-9]+','[redacted]',detail)
+    detail=re.sub(r'(?i)\bBearer\s+[^\s\"\'<>]+','Bearer [redacted]',detail)
+    detail=re.sub(r'https?://[^\s\"\'<>]+','[remote URL]',detail)
+    detail=re.sub(r'(?i)\b(token|api[_-]?key|password|secret)\s*[:=]\s*[^\s,;]+',r'\1=[redacted]',detail)
+    return detail[:2000]
+
+
 def encode_remote(prompt,references,canvas,num_frames,rewrite_prompt=False,session_id='',reference_resize_mode='legacy'):
     from gradio_client import handle_file
     from safetensors import safe_open
@@ -4340,6 +4353,7 @@ def encode_remote(prompt,references,canvas,num_frames,rewrite_prompt=False,sessi
             except Exception:
                 _CONDITION_CACHE.pop(key,None)
     job=None
+    stage='submitting'
     try:
         fields=dict(prompt=prompt,media=[handle_file(p) for _,p in references],
             kinds=','.join(k for k,_ in references),num_frames=num_frames,rewrite_prompt=bool(rewrite_prompt))
@@ -4349,13 +4363,26 @@ def encode_remote(prompt,references,canvas,num_frames,rewrite_prompt=False,sessi
         else:
             fields.update(canvas=canvas,api_name='/encode_ref2va')
         job=conditioner().submit(**fields)
+        stage='waiting_for_conditioner'
         path,plan=job.result(timeout=300)
+        stage='reading_conditioning'
         result=read(path,plan)
     except Exception as error:
         if job is not None:
             try:job.cancel()
             except Exception:pass
-        raise gr.Error(f'Conditioner failed ({type(error).__name__}). No retry was submitted. A started remote job may still use quota.') from None
+        import html
+        detail=_conditioner_error_detail(error)
+        # Do not discard the upstream AppError: it carries the actual failure.
+        # No traceback locals, prompt or upload data are added to diagnostics.
+        _runtime_event('conditioner_failed',stage=stage,error_type=type(error).__name__)
+        print('[conditioner-error] '+json.dumps(dict(stage=stage,error_type=type(error).__name__,detail=detail),ensure_ascii=False),flush=True)
+        raise gr.Error(
+            f'Conditioner failed ({type(error).__name__}; {stage}): {html.escape(detail)}\n\n'
+            'No video GPU request was sent. No retry was submitted. '
+            'A started conditioner job may still use quota. If the message has no details, '
+            'open Logs in the conditioner Space and copy its traceback.'
+        ) from None
     if key and os.path.getsize(path)<=256*1048576:
         root=os.path.join(tempfile.gettempdir(),'h3-condition-cache');os.makedirs(root,exist_ok=True)
         dest=os.path.join(root,key+'.safetensors');temporary=dest+'.'+uuid.uuid4().hex