fluid scaffold-composer
Generate a Cloud Composer (Airflow) DAG from a contract.
Syntax
fluid scaffold-composer CONTRACT [--env ENV] [--out-dir DIR]
Key options
| Option | Description |
|---|---|
CONTRACT | Path to contract.fluid.yaml (positional, required). |
--env | Overlay env to apply before reading the contract. |
--out-dir | DAGs output directory (default runtime/composer/dags). |
Examples
fluid scaffold-composer contract.fluid.yaml
fluid scaffold-composer contract.fluid.yaml --env prod
fluid scaffold-composer contract.fluid.yaml --out-dir dags/
Notes
- Writes one
<dag_id>.pyfile per contract, wheredag_idcomes fromid(orname) with.replaced by_. - The generated DAG has three sequential
BashOperatortasks:validate,plan,apply. Theapplystep runs against the GCP provider with--yes. - Schedule is read from
build.execution.trigger.cronin the contract; if missing, defaults to0 2 * * *(daily at 02:00). - For non-Composer Airflow installs, see
fluid generate-airflow. For broader pipeline generation across orchestrators, seefluid generate-pipeline.