queue_example.py

"""Seedance 2.0 — async queue example with polling.

Use the queue API when you want to submit a long-running job, do other work,
and pick up the result later (or hand off to a webhook).
"""

import os
import sys
import time

import fal_client


MODEL_ID = "bytedance/seedance-2.0/fast/text-to-video"


def main() -> int:
    if not os.environ.get("FAL_KEY"):
        print("Error: FAL_KEY environment variable is not set.", file=sys.stderr)
        return 1

    handle = fal_client.submit(
        MODEL_ID,
        arguments={
            "prompt": (
                "Aerial drone shot sweeping over a misty alpine lake at sunrise, "
                "lone kayaker paddling across glassy water, ambient birdsong."
            ),
            "resolution": "720p",
            "duration": "6",
            "aspect_ratio": "21:9",
            "generate_audio": True,
        },
    )
    request_id = handle.request_id
    print(f"Submitted. request_id={request_id}")

    while True:
        status = fal_client.status(MODEL_ID, request_id, with_logs=True)
        print(f"status: {type(status).__name__}")
        if isinstance(status, fal_client.Completed):
            break
        time.sleep(3)

    result = fal_client.result(MODEL_ID, request_id)
    print("Video URL:", result["video"]["url"])
    print("Seed:     ", result["seed"])
    return 0


if __name__ == "__main__":
    raise SystemExit(main())