Fix WaveSpeed async job handling - add polling for outputs

WaveSpeed returns async responses with urls.get for some models.
Added _poll_for_result method to poll until outputs are ready.
Also added _resolve_video_model helper.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

src/content_engine/services/cloud_providers/wavespeed_provider.py

@@ -151,6 +151,62 @@ class WaveSpeedProvider(CloudProvider):
             return model_name
         return EDIT_MODEL_MAP["default"]
 
+    def _resolve_video_model(self, model_name: str | None) -> str:
+        """Resolve a friendly name to a WaveSpeed video model API path."""
+        if model_name and model_name in VIDEO_MODEL_MAP:
+            return VIDEO_MODEL_MAP[model_name]
+        if model_name:
+            return model_name
+        return VIDEO_MODEL_MAP["default"]
+
+    async def _poll_for_result(self, poll_url: str, max_attempts: int = 60, interval: float = 2.0) -> str:
+        """Poll the WaveSpeed async job URL until outputs are ready.
+
+        Returns the first output URL when available.
+        """
+        import asyncio
+
+        for attempt in range(max_attempts):
+            try:
+                resp = await self._http_client.get(
+                    poll_url,
+                    headers={"Authorization": f"Bearer {self._api_key}"},
+                )
+                resp.raise_for_status()
+                result = resp.json()
+
+                data = result.get("data", result)
+                status = data.get("status", "")
+
+                if status == "failed":
+                    error_msg = data.get("error", "Unknown error")
+                    raise RuntimeError(f"WaveSpeed job failed: {error_msg}")
+
+                outputs = data.get("outputs", [])
+                if outputs:
+                    logger.info("WaveSpeed job completed after %d polls", attempt + 1)
+                    return outputs[0]
+
+                # Also check for 'output' field
+                if "output" in data:
+                    out = data["output"]
+                    if isinstance(out, list) and out:
+                        return out[0]
+                    elif isinstance(out, str):
+                        return out
+
+                if status == "completed" and not outputs:
+                    raise RuntimeError(f"WaveSpeed job completed but no outputs: {data}")
+
+                logger.debug("WaveSpeed job pending (attempt %d/%d)", attempt + 1, max_attempts)
+                await asyncio.sleep(interval)
+
+            except httpx.HTTPStatusError as e:
+                logger.warning("Poll request failed: %s", e)
+                await asyncio.sleep(interval)
+
+        raise RuntimeError(f"WaveSpeed job timed out after {max_attempts * interval}s")
+
     @staticmethod
     def _ensure_min_image_size(image_bytes: bytes, min_pixels: int = 3686400) -> bytes:
         """Upscale image if total pixel count is below the minimum required by the API.
@@ -425,6 +481,11 @@ class WaveSpeedProvider(CloudProvider):
                     image_url = out[0]
                 elif isinstance(out, str):
                     image_url = out
+            # Async response: outputs empty but urls.get exists - need to poll
+            elif not outputs and "urls" in data and "get" in data.get("urls", {}):
+                poll_url = data["urls"]["get"]
+                logger.info("WaveSpeed returned async job, polling: %s", poll_url[:80])
+                image_url = await self._poll_for_result(poll_url)
         elif isinstance(output, list) and output:
             image_url = output[0]
         elif isinstance(output, str):