gcp-pipeline-orchestration

Generate, validate, deploy, and trigger Google Cloud Composer orchestration pipeline definitions.

Updated Aug 16, 2026
One-click install
npx skills add https://github.com/1919114514yasenpai-maker/focus-quest --skill gcp-pipeline-orchestration-1919114514yasenpai-maker
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: gcp-pipeline-orchestration
Source: https://github.com/1919114514yasenpai-maker/focus-quest/tree/main/.gemini/skills/gcp-pipeline-orchestration
Command: npx skills add https://github.com/1919114514yasenpai-maker/focus-quest --skill gcp-pipeline-orchestration-1919114514yasenpai-maker

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill requires google-auth, requests, and includes scripts (resource) and references (resource) components.

What problem does it solve? Setting up data pipeline orchestration on Google Cloud Composer requires correctly authoring two interdependent YAML files (an orchestration pipeline definition and a deployment.yaml), selecting compatible Composer and Dataproc environments, and running validation, deployment, and triggering commands in the right order. This Skill automates that entire workflow so pipelines are created, validated, and run without manual trial and error. ## Core Features & Use Cases - Pipeline Generation & Initialization: Scaffold projects with gcloud beta orchestration-pipelines init and generate orchestration YAML for dbt, Dataform, PySpark, notebooks, Python scripts, and BigQuery SQL actions. - Environment-Aware Deployment: Discover Dataproc clusters and Composer environments via gcloud, verify compatible image versions and PyPI packages, and fill deployment.yaml with real project, region, and bucket values. - Validation, Deploy & Trigger: Validate every environment with gcloud beta orchestration-pipelines validate, deploy with --local, poll for DAG readiness, trigger runs, and pause or unpause pipelines. - Use Case: A data engineer asks to orchestrate a dbt project that runs after a PySpark job on a schedule; the Skill generates both YAML files, validates them against the dev environment, deploys the DAG to Composer, and triggers the first run. ## Quick Start Ask the agent to create and validate a Cloud Composer orchestration pipeline for your dbt or Spark jobs in the dev environment.

Frequently Asked Questions about gcp-pipeline-orchestration

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I create a Cloud Composer orchestration pipeline with gcloud?▼

Run `gcloud beta orchestration-pipelines init <name> --environment=<env>` to scaffold the project, then author the orchestration YAML and deployment.yaml files. Validate with `gcloud beta orchestration-pipelines validate --environment=<env>` before deploying.

How to schedule dbt and PySpark jobs together in one pipeline?▼

Define actions in the orchestration YAML using `- pyspark:` and `- pipeline:` entries, linking them with `dependsOn`. The dbt action uses the airflowWorker framework with a projectDirectoryPath, while PySpark runs on a Dataproc cluster or serverless engine.

Which Composer image versions support orchestration pipelines?▼

Supported images include composer-3-airflow-3.1.7, 2.11.1, 2.10.5, 2.9.3 builds and composer-2.16.11 variants, or any environment with the orchestration-pipelines PyPI package installed. Check with `gcloud composer environments describe` and inspect the softwareConfig.

Why does orchestration pipeline validation fail after generating YAML?▼

Common causes include missing endTime on schedules, using snake_case instead of camelCase field names, or placeholder values left in deployment.yaml. Read the validate command error, fix the specific field, and re-run validation until it exits with code 0.

Can I trigger a deployed Composer DAG without redeploying?▼

Yes. Use `gcloud beta orchestration-pipelines list --environment=<env>` to find the existing bundle ID, then run the trigger command with that bundle and pipeline ID. A fallback Python script can also trigger the DAG directly through the Airflow API.