시도 하나에 키 하나

def is_clip(task):
    return task.get("media") == "clip"


def clip_request_id(task):
    """One idempotency key per attempt: re-posting it after a crash returns
    the clip Ember already made instead of paying for another."""
    return f"avatars-{task['id']}-{len(task['attempts']) + 1}"

            settings = task["clip"]
            body = {"request_id": clip_request_id(task), "generator": task["provider"], "prompt": task["prompt"], "aspect_ratio": settings["aspect_ratio"], "resolution": settings["resolution"], "duration_secs": settings["duration_secs"], "audio": settings["audio"], "negative_prompt": settings.get("negative_prompt"), "inputs": inputs,
                    # Consent was settled when the batch was accepted (studio.generate).
                    "confirm": True,
                    "source_metadata": {**batch["request"].get("source_metadata", {}), "source_app": "cwkAvatars", "batch_id": batch["id"], "task_id": id, "attempt": len(task["attempts"]) + 1, "soul_ids": task["subjects"], "ordinal": task["ordinal"]}}
            task = await io("update", id, expected=task["version"], state="submitting", phase="Submitting to Ember", submitted_at=now())
            try:
                accepted = await upstream.video_create(body)
            except StudioError as exc:
                if 400 <= exc.status < 500:
                    await io("update", id, state="failed", error=str(exc), phase="Submission refused")
                else:
                    # The same request id is safe to send again: leave it for the next pass.
                    await io("update", id, state="queued", phase="Ember unreachable; will retry", error=str(exc))
                    await asyncio.sleep(10)
                return
            task = await io("update", id, state="running", phase=accepted.get("phase") or "Generating", job_id=accepted["id"], error=None, attempts=[*task["attempts"], {"job_id": accepted["id"], "submitted_at": task["submitted_at"]}])

        for task in await self.studio.io("list", "task", states=("preparing",)):
            await self.studio.io("update", task["id"], state="queued", phase="Queued")
        for task in await self.studio.io("list", "task", states=("submitting",)):
            if is_clip(task):
                # The clip's request id makes the submit idempotent in Ember.
                await self.studio.io("update", task["id"], state="queued", phase="Queued")
                continue
            await self.studio.io("update", task["id"], state="uncertain", phase="Reconcile before retry", error="The previous submit may have reached Ember. Check history before submitting again.")