What problem does it solve?
Generating synthetic anomaly videos (falls, fights, theft, fire) for safety and surveillance AI training requires orchestrating a complex multi-stage pipeline: Cosmos3 image-to-video generation, auto-labeling, and anomaly dataset assembly on Kubernetes. This Skill guides an agent through the entire PAIDF Orchestration Event Video Generation DAG lifecycle without manual Airflow or kubectl expertise.
Core Features & Use Cases
- End-to-End DAG Orchestration: Prepares seed-image inputs, renders validated payloads, triggers the
event_video_generation_dag_k8s DAG via the Airflow API, and monitors runs to completion.
- Readiness Preflight: Verifies controller pods, Airflow API health, pool slots, and GPU capacity (3 GPUs minimum for external mode, 7 for internal mode) before triggering.
- Payload Validation & Results Analysis: Bundled scripts render/validate
EventVideoGenerationDagPayloadConfig-compatible JSON, upload seed images to S3, and summarize the generated anomaly dataset.
- Use Case: A robotics engineer needs 30 synthetic person-falling videos in a warehouse setting. The agent uploads seed images, renders an external-mode payload with a weighted anomaly distribution, triggers the DAG, monitors the run, and summarizes the resulting labeled dataset.
Quick Start
Ask your agent to run event video generation on your seed images at an S3 path with your VLM, LLM, and image2video endpoint URLs on Kubernetes.