Stats
Actions
Tags
Help us improve
Share bugs, ideas, or general feedback.
From godmode
Designs, implements, tests, and debugs data pipelines and ETL with quality validation, schema contracts, observability, and error handling. Supports Airflow, dbt, Dagster, Prefect.
npx claudepluginhub arbazkhan971/godmodeHow this command is triggered — by the user, by Claude, or both
Slash command
/godmode:pipelinegodmode/The summary Claude sees in its command listing — used to decide when to auto-load this command
# /godmode:pipeline Data pipeline and ETL design, implementation, testing, and debugging. Covers extraction, transformation, loading, data quality validation, schema contracts, observability, and error handling. Works with any orchestrator (Airflow, dbt, Dagster, Prefect, Luigi, custom scripts) and any data store. ## Usage ## What It Does 1. Maps the complete data flow (sources, transformations, targets, schedule, SLA) 2. Detects the orchestration tool (Airflow, dbt, Dagster, Prefect, etc.) 3. Designs pipeline architecture (batch, streaming, CDC, ELT) 4. Implements: extractors with wa...
/pipelineScaffolds data pipelines (Airflow, Dagster) with best-practice patterns — generates DAG structure, task definitions, error handling, and scheduling from a description or spec file.
/etlDesigns and implements ETL/ELT data pipelines based on a required requirement and optional pattern like batch or streaming.
/pipelineCreates or repairs Redpanda Connect pipeline configurations interactively with guidance and validation, using required context and optional existing file.
/pipelineAnalyzes content from one or more URLs to extract structural, psychological, and mechanical patterns, producing an anatomy guide and interview questions.
/pipelineOrchestrates multi-step design pipelines with run, list, show, and new subcommands. Supports browser research steps via Playwright and memory injection from project context.
Share bugs, ideas, or general feedback.
Data pipeline and ETL design, implementation, testing, and debugging. Covers extraction, transformation, loading, data quality validation, schema contracts, observability, and error handling. Works with any orchestrator (Airflow, dbt, Dagster, Prefect, Luigi, custom scripts) and any data store.
/godmode:pipeline # Interactive pipeline design workflow
/godmode:pipeline --design # Design architecture without implementing
/godmode:pipeline --implement # Implement from existing design
/godmode:pipeline --test # Run pipeline tests (unit + integration)
/godmode:pipeline --backfill 2025-01-01:2025-01-31 # Run for historical date range
/godmode:pipeline --validate # Run data quality checks on last output
/godmode:pipeline --debug # Investigate a failing pipeline
/godmode:pipeline --status # Show run history and health
/godmode:pipeline --dry-run # Show what pipeline would do without executing
/godmode:pipeline --profile # Profile performance (time per stage)
/godmode:pipeline --schema # Show schema contracts for all boundaries
/godmode:pipeline --reconcile # Run source-target reconciliation
/godmode:pipeline --dbt # Focus on dbt model design and testing
/godmode:pipeline --streaming # Design a streaming pipeline
/godmode:pipeline --monitor # Set up monitoring and alerting
"pipeline: <name> -- <source> to <target>, <schedule>"After pipeline: /godmode:query to optimize pipeline queries, /godmode:migrate if schema changes needed, or /godmode:ship to deploy.
/godmode:pipeline Sync orders from Postgres to BigQuery, daily at 2 AM
/godmode:pipeline --debug Our nightly ETL has been failing for 3 days
/godmode:pipeline --dbt Build staging and mart models for the orders domain
/godmode:pipeline --streaming Clickstream from Kafka to Elasticsearch
/godmode:pipeline --backfill 2024-01-01:2024-12-31 # Load historical data
/godmode:pipeline --reconcile # Verify source matches target