Update yml/ltxvideo.py

yml/ltxvideo.py

@@ -87,6 +87,16 @@ def report_failure(error_msg):
                             new_encoded = base64.b64encode(json.dumps(config).encode('utf-8')).decode('utf-8')
                             new_raw_prompt = f"VOICECONFIG_LTX_{new_encoded}"
                             
+                            # آپلود فایل نشانگر وضعیت پردازش پس‌زمینه برای مرورگر کاربر
+                            with open("processing.txt", "w", encoding="utf-8") as pf:
+                                pf.write("processing")
+                            requests.post(
+                                f"{space_url}/api/webhook/upload",
+                                data={'run_id': f"{original_run_id}_processing", 'github_run_id': github_run_id, 'ext': 'txt'},
+                                files={'file': open("processing.txt", "rb")},
+                                timeout=30
+                            )
+                            
                             spawn_res = requests.post(
                                 f"{space_url}/api/generate",
                                 json={
@@ -97,8 +107,18 @@ def report_failure(error_msg):
                             )
                             print(f"   -> Spawned new cycle status: {spawn_res.status_code} - Server Resp: {spawn_res.text}", flush=True)
                         else:
-                            # اگر پس از ۶۰ تلاش کل فرآیند شکست خورد، کارت خطای ساخته شده را روی آیدی اولیه کاربر مپ می‌کنیم
+                            # اگر پس از ۶۰ تلاش کل فرآیند شکست خورد، وضعیت را خاتمه یافته اعلام کرده و کارت خطا را مپ می‌کنیم
                             print(f"❌ Max cycles reached ({cycle_count}/3). Mapping final error card back to original ID: {original_run_id}", flush=True)
+                            
+                            with open("processing.txt", "w", encoding="utf-8") as pf:
+                                pf.write("failed")
+                            requests.post(
+                                f"{space_url}/api/webhook/upload",
+                                data={'run_id': f"{original_run_id}_processing", 'github_run_id': github_run_id, 'ext': 'txt'},
+                                files={'file': open("processing.txt", "rb")},
+                                timeout=30
+                            )
+                            
                             time.sleep(5)  # زمان کوتاه برای اطمینان از ذخیره کامل فایل خطا روی سرور
                             error_card_url = f"{space_url}/static/images/{run_id}.png"
                             err_req = requests.get(error_card_url, timeout=20)
@@ -320,6 +340,16 @@ if video_path.endswith('.webm'):
     ext = 'webm'
 
 try:
+    # تغییر وضعیت فایل موقت پایش فرانت‌اند به اتمام پردازش موفقیت‌آمیز
+    with open("processing.txt", "w", encoding="utf-8") as pf:
+        pf.write("done")
+    requests.post(
+        f"{space_url}/api/webhook/upload",
+        data={'run_id': f"{original_run_id}_processing", 'github_run_id': github_run_id, 'ext': 'txt'},
+        files={'file': open("processing.txt", "rb")},
+        timeout=30
+    )
+
     with open(video_path, 'rb') as f:
         requests.post(
             f"{space_url}/api/webhook/upload",