priompt

prompt/animation.md

@@ -0,0 +1 @@
+Analyze this image and create a concise prompt for a video generation model to create a cinematic, loopable animation. Identify the most interesting moving element (e.g., flowing water, swaying trees, flickering light, clouds) and describe the motion. Output ONLY the description, under 30 words.

services/gemini_job_worker.py

@@ -150,10 +150,44 @@ class GeminiJobProcessor(JobProcessor[GeminiJob]):
     
     async def _start_video(self, job: GeminiJob, session: AsyncSession, service: GeminiService, input_data: dict) -> GeminiJob:
         """Start async video generation."""
+        prompt = input_data.get("prompt", "")
+        
+        # If prompt is missing, generate one using the animation template
+        if not prompt:
+            try:
+                import os
+                template_path = os.path.join(os.path.dirname(os.path.dirname(__file__)), "prompt", "animation.md")
+                if os.path.exists(template_path):
+                    with open(template_path, "r") as f:
+                        template_prompt = f.read().strip()
+                    
+                    logger.info(f"Generating auto-prompt for job {job.job_id} using template")
+                    prompt = await service.generate_animation_prompt(
+                        base64_image=input_data.get("base64_image", ""),
+                        mime_type=input_data.get("mime_type", "image/jpeg"),
+                        custom_prompt=template_prompt
+                    )
+                    logger.info(f"Generated prompt for job {job.job_id}: {prompt}")
+                    
+                    # Update input data with generated prompt for reference
+                    input_data["prompt"] = prompt
+                    job.input_data = input_data
+                    # We need to commit this change to DB so it persists
+                    # But session commit happens outside this method usually? 
+                    # Actually process() calls this, and process() returns job, 
+                    # but doesn't explicitly commit job changes until later?
+                    # The worker loop commits after process() returns.
+                else:
+                    logger.warning(f"Animation prompt template not found at {template_path}")
+            except Exception as e:
+                logger.error(f"Failed to generate auto-prompt: {e}")
+                # Fallback to empty prompt or error? 
+                # Let's let it proceed with empty prompt which might fail at API level or use API default
+        
         result = await service.start_video_generation(
             base64_image=input_data.get("base64_image", ""),
             mime_type=input_data.get("mime_type", "image/jpeg"),
-            prompt=input_data.get("prompt", ""),
+            prompt=prompt,
             aspect_ratio=input_data.get("aspect_ratio", "16:9"),
             resolution=input_data.get("resolution", "720p"),
             number_of_videos=input_data.get("number_of_videos", 1)