Update app.py

app.py

@@ -13,7 +13,7 @@ from huggingface_hub import login
 # --- 1. Configuration and Authentication ---
 
 # IMPORTANT: Replace with your Google Cloud Project ID
-GCP_PROJECT_ID = "gen-lang-client-0193353123" # Make sure this is replaced!
+GCP_PROJECT_ID = "YOUR_GCP_PROJECT_ID" # Make sure this is replaced!
 GCP_LOCATION = "us-central1"
 MODEL_ID = "veo-3.0-generate-preview"
 API_ENDPOINT = f"{GCP_LOCATION}-aiplatform.googleapis.com"
@@ -51,7 +51,7 @@ else:
         credentials.refresh(auth_req)
         return credentials.token
 
-    # --- 2. Core Video Generation Logic (WITH FIX) ---
+    # --- 2. Core Video Generation Logic (WITH FINAL FIX) ---
 
     def generate_video(prompt: str):
         if not prompt:
@@ -66,17 +66,12 @@ else:
                 "Content-Type": "application/json",
             }
 
-            # --- Step A: Submit the long-running prediction job ---
             payload = {
                 "instances": [{"prompt": prompt}],
                 "parameters": {
-                    "aspectRatio": "16:9",
-                    "sampleCount": 1,
-                    "durationSeconds": 8,
-                    "personGeneration": "allow_all",
-                    "addWatermark": True,
-                    "includeRaiReason": True,
-                    "generateAudio": True,
+                    "aspectRatio": "16:9", "sampleCount": 1, "durationSeconds": 8,
+                    "personGeneration": "allow_all", "addWatermark": True,
+                    "includeRaiReason": True, "generateAudio": True,
                 }
             }
             
@@ -86,7 +81,6 @@ else:
             operation_name = response.json()["name"]
             print(f"Successfully submitted job. Operation Name: {operation_name}")
 
-            # --- Step B: Poll for the result ---
             MAX_POLL_ATTEMPTS = 60 
             for i in range(MAX_POLL_ATTEMPTS):
                 status_message = f"Status: Job submitted. Polling for result (Attempt {i+1}/{MAX_POLL_ATTEMPTS})... Please wait."
@@ -103,16 +97,13 @@ else:
 
                 if poll_result.get("done"):
                     print("Job finished successfully.")
-                    # --- START: ROBUST RESPONSE HANDLING FIX ---
-                    
-                    # For debugging, print the entire final response from Google
                     print(f"Full successful response payload: {json.dumps(poll_result, indent=2)}")
 
                     response_data = poll_result.get("response", {})
                     
-                    # Check if the 'predictions' key exists and is not empty
-                    if "predictions" in response_data and response_data["predictions"]:
-                        video_base64 = response_data["predictions"][0]["bytesBase64Encoded"]
+                    # <<< FIX: Changed "predictions" to "videos" to match the actual API response >>>
+                    if "videos" in response_data and response_data["videos"]:
+                        video_base64 = response_data["videos"][0]["bytesBase64Encoded"]
                         video_bytes = base64.b64decode(video_base64)
                         
                         temp_video_path = "generated_video.mp4"
@@ -122,23 +113,18 @@ else:
                         yield "Status: Done! Video generated successfully.", temp_video_path
                         return
                     else:
-                        # This branch handles cases where the job is "done" but no video was returned,
-                        # most likely due to safety filters.
                         error_message = "Video generation finished, but the content was blocked by safety filters or another issue prevented video creation."
                         print(f"ERROR: {error_message}")
                         raise gr.Error(error_message)
-
-                    # --- END: ROBUST RESPONSE HANDLING FIX ---
                 
                 time.sleep(10)
 
-            raise gr.Error("Operation timed out after several minutes. The job may have failed or is taking too long.")
+            raise gr.Error("Operation timed out after several minutes.")
 
         except requests.exceptions.HTTPError as e:
             print(f"HTTP Error: {e.response.text}")
             raise gr.Error(f"API Error: {e.response.status_code}. Details: {e.response.text}")
         except Exception as e:
-            # Catch the specific Gradio error we raised, and any other unexpected errors.
             print(f"An error occurred in the generation process: {e}")
             raise gr.Error(str(e))