What problem does it solve?
This skill automates the generation, deployment, and triggering of orchestration pipelines for Google Cloud Composer, simplifying complex data workflows.
Core Features & Use Cases
- Pipeline Generation: Create or update Cloud Composer orchestration pipeline definitions (YAML) for various tasks like dbt, notebooks, Spark jobs, Dataform, Python scripts, and BigQuery SQL.
- Deployment Management: Handle the deployment of orchestration pipelines to specified environments, ensuring compatibility checks and placeholder replacements.
- Pipeline Triggering: Initiate pipeline runs either locally for validation or in production environments, following a deploy-poll-trigger flow.
- Use Case: Manage end-to-end data pipeline orchestration within a GCP environment using Airflow on Cloud Composer.
Quick Start
Ask the user for the pipeline name and environment, then run gcloud beta orchestration-pipelines init <PIPELINE_NAME> --environment=<ENV_NAME> to scaffold the project if necessary, followed by creating/validating orchestration-pipeline.yaml and deployment.yaml.