
Data Engineering Agent Skills
🌐 Project Website | 📦 VS Code Marketplace | 🔌 JetBrains Marketplace | ⬇️ GitHub Releases
Production-grade data engineering skills for AI agents.
The open skill registry and execution toolkit for data engineering agents.
This repository packages repeatable workflows, quality gates, hooks, installer surfaces, and example packs (runnable scaffolds plus architecture blueprints) so agents can build data systems with the same discipline used by strong data engineering teams.
The goal is not to give agents generic prompts. The goal is to give them operating procedures for defining, planning, implementing, validating, replaying, and shipping reliable data products.
Agent Skills Registry Compatibility
This repository is structured to work with open Agent Skills registries:
- every capability lives in a directory containing a
SKILL.md - every
SKILL.mdstarts with YAML frontmatter including at leastnameanddescription - descriptions are written for progressive disclosure so agents can decide when to load the full skill
- supporting materials can live in
references/,templates/,examples/,hooks/, andscripts/
Real setup paths:
git clone https://github.com/vaquarkhan/data-engineering-agent-skills.git
scripts/install.sh --tool all --target /path/to/project
Windows-friendly file install:
pwsh scripts/install.ps1 --tool all --target C:\path\to\project
If your agent or editor supports importing a GitHub-hosted skill registry directly, use that tool's documented repository-install command against this repository URL rather than the example syntax from another project.
For Python-based proof assets and validators, install local dependencies with:
pip install -r requirements.txt
Contract validation quickstart
The dataset contract validator checks sample data against templates/dataset-contract.yaml-style contracts. It requires a contract file and a data source (--data or --duckdb); validating a template alone will error by design.
python scripts/validate_dataset_contract.py --help
python scripts/validate_dataset_contract.py \
--contract examples/aws-s3-glue-athena-iceberg/contracts/customers-contract.yaml \
--data examples/aws-s3-glue-athena-iceberg/data/customers.jsonl \
--reference-time 2026-05-02T00:00:00Z
For dbt + DuckDB local proof:
python scripts/validate_dataset_contract.py \
--contract examples/dbt-warehouse-marts/contracts/fct_daily_revenue-contract.yaml \
--duckdb examples/dbt-warehouse-marts/build/dbt_warehouse_marts.duckdb \
--query "select * from fct_daily_revenue order by order_date"
Bootstrap install shortcuts:
./bootstrap.sh /path/to/project auto
pwsh .\bootstrap.ps1 C:\path\to\project auto
Quick Start
Start Here
- load
skills/using-data-engineering-agent-skills/SKILL.md - pick the closest platform preset from
presets/ - choose the safest next command from the lifecycle below
- use one starter pack, template, or example to reduce guessing
Install Surfaces
📦 Plugin And Release Downloads
⬇️ Install from VS Code Marketplace — search "Data Engineering Agent Skills" in VS Code Extensions panel
⬇️ Install from JetBrains Marketplace — IntelliJ, PyCharm, DataGrip, WebStorm, GoLand
⬇️ Download VS Code Extension (.vsix) — manual install for VS Code, Cursor, Windsurf, VSCodium
⬇️ Download JetBrains Plugin (.zip) — alternative manual download
How to install the .vsix:
- Download the
.vsixfile from the latest release - Open VS Code / Cursor / Windsurf / Kiro
- Press
Ctrl+Shift+P(orCmd+Shift+Pon Mac) to open the Command Palette - Type
Extensions: Install from VSIX...and select it - Browse to and select the downloaded
.vsixfile - Reload the editor when prompted
- Use the Command Palette again — search for
Data Engineering Skills:to see all available commands
How to install the JetBrains .zip:
- Download the
.zipfile from the latest release - Open IntelliJ / PyCharm / DataGrip
- Go to
Settings→Plugins→ ⚙️ gear icon →Install Plugin from Disk... - Select the downloaded
.zipfile - Restart the IDE when prompted
Additional plugin resources:
- plugin publishing and marketplace workflow setup:
docs/plugin-publishing.md - marketplace publish workflows exist, but this repository should be treated as GitHub Releases-first unless a marketplace listing is explicitly published
Claudeplugin bundle: use.claude-plugin/,.claude/commands/, andCLAUDE.md
Install By Tool
| Tool or surface | Best starting link | Install path |
|---|---|---|
VS Code |
vscode-extension/README.md |
Install from Marketplace or download .vsix from Releases |
Cursor |
docs/cursor-setup.md |
use .cursor/rules/ or scripts/install.sh --tool cursor |
Claude |
docs/claude-setup.md |
use .claude/commands/, .claude-plugin/, CLAUDE.md, or scripts/install.sh --tool claude |
JetBrains |
docs/jetbrains-setup.md |
Install from Marketplace or download .zip from Releases |
Copilot |
docs/copilot-setup.md |
use .github/copilot-instructions.md or scripts/install.sh --tool copilot |
Kiro |
docs/kiro-setup.md |
use .kiro/steering/ or scripts/install.sh --tool kiro |
Windsurf |
docs/windsurf-setup.md |
use .windsurfrules.example or scripts/install.sh --tool windsurf |
OpenCode |
docs/opencode-setup.md |
use .opencode/ or scripts/install.sh --tool opencode |
Codex |
docs/codex-setup.md |
use AGENTS.md, CLAUDE.md, skills-index.md, and docs/codex-setup.md |
generic AGENTS.md consumers |
docs/getting-started.md |
use scripts/install.sh --tool all or copy the core files manually |
One-Line Script Install
scripts/install.sh --tool claude --target /path/to/project
scripts/install.sh --tool kiro --target /path/to/project
scripts/install.sh --tool windsurf --target /path/to/project
scripts/install.sh --tool opencode --target /path/to/project
scripts/install.sh --tool all --target /path/to/project
scripts/install.sh --tool auto --target /path/to/project
scripts/install.sh --tool cursor,claude --target /path/to/project
scripts/install.sh --tool all --target /path/to/project --symlink
Windows-friendly install path:
pwsh scripts/install.ps1 --tool all --target C:\path\to\project
Evaluation runner:
python evals/run.py
Tool Setup Guides
docs/getting-started.mddocs/cursor-setup.mddocs/kiro-setup.mddocs/claude-setup.mddocs/copilot-setup.mddocs/windsurf-setup.mddocs/opencode-setup.mddocs/codex-setup.mddocs/jetbrains-setup.mddocs/plugin-publishing.md
Tutorials
tutorials/README.mdtutorials/using-data-engineering-agent-skills.mdtutorials/cloud-data-engineering-architecture-patterns.mdtutorials/pipeline-orchestration-patterns.mdtutorials/streaming-architecture-patterns.mdtutorials/data-resiliency-testing-patterns.mdtutorials/etl-elt-modernization-and-cutover.mdtutorials/regulated-data-and-compliance-workflows.mdtutorials/installing-vscode-and-jetbrains-plugins.md
Case Studies
case-studies/README.mdcase-studies/incident-bad-publish-recovery.mdcase-studies/replay-safe-backfill-after-corruption.mdcase-studies/regulated-data-release-gate.md
Core Principles
- Spec before pipeline code
- Contract-first source and output design
- Idempotent, replayable, backfill-safe execution
- Data quality checks before publish
- Lineage, ownership, and governance by default
- Clear evidence for every change
Feature Highlights
- Spec-first lifecycle with
/spec,/plan,/build,/validate,/review,/backfill, and/ship - 73 workflow skills covering ingestion, transformation, orchestration, streaming, lakehouse, warehousing, governance, quality tooling, legacy modernization, release, incident recovery, and platform operating concerns, plus 1 compatibility alias entry skill
- focused resilience testing coverage for failure drills, replay safety, restart behavior, backlog catch-up, publish protection, and disaster recovery readiness
- 14 platform presets spanning
AWS,Azure,GCP,Databricks,Snowflake,Alibaba Cloud,Informatica,Talend, and Apache-first stacks - Multi-agent packaging for
Cursor,Claude,Copilot,Gemini,Codex,Kiro,OpenCode,Windsurf,AGENTS.md, andCLAUDE.mdconsumers - Install surfaces for
VS Codefamily editors,JetBrainsIDEs, setup guides, one-line install scripts, and plugin release artifacts - Plugin delivery and discovery workflows for
VS CodeandJetBrains, including release downloads, install smoke tests, markdown linting, and optional marketplace publish automation - 5 runnable example scaffolds with contract validation, rollback demonstrations, and smoke-test proof paths, plus 9 architecture blueprint examples (spec/plan/tasks only)
- Agent benchmark pack with quantified with-skills coverage improvement (23→67 on the included task set)
- Structured operational templates for dataset contracts, compliance controls, backfills, schema changes, release gates, and incident response
Feature Coverage
| Area | What is included | Good starting point |
|---|---|---|
| Core delivery workflow | Spec-driven delivery, planning, validation, review, publish readiness, replay safety, and rollback-aware release flow | skills/using-data-engineering-agent-skills/SKILL.md |
| Cloud and platform coverage | AWS, Azure, GCP, Databricks, Snowflake, Alibaba Cloud, multi-cloud and hybrid guidance |
presets/ |
| Apache and OSS data stack | Spark, Flink, Airflow, Kafka, Iceberg, Hudi, Beam, Trino, ClickHouse, DuckDB, LakeFS, OpenMetadata, DataHub, OpenLineage, Great Expectations, Deequ, Cuallee, Soda, Superset, and schema-registry patterns |
skills-index.md |
| Orchestration and streaming | Scheduler-driven, event-driven, and lakehouse-native orchestration patterns plus replay-safe streaming architecture guidance | references/pipeline-orchestration-patterns.md, references/streaming-architecture-patterns.md |
| Security, governance, and regulated data | PII, PCI, HIPAA, lineage, retention, deletion, privacy, audit evidence, platform security, publish controls, and cloud-native governance for Glue Data Catalog, Lake Formation, Unity Catalog, Purview, and Dataplex |
skills/data-security-compliance-and-regulated-data/SKILL.md, references/platform-native-governance-patterns.md |
| Regional compliance and reporting | GDPR, sovereignty and residency patterns, SAMA, Europe, USA, India, Saudi Arabia, CSRD, ESRS, BRSR, and ESG reporting workflows |
references/regional-compliance-and-data-sovereignty-checklist.md, references/esg-and-sustainability-reporting-checklist.md |
| Modernization and enterprise ETL | ETL versus ELT, data migration, cutover, enterprise ETL modernization, mainframe offload, and guidance for Informatica, Talend, DataStage, SSIS, Matillion, and mainframe-origin estates |
skills/etl-elt-and-modernization-strategy/SKILL.md, skills/mainframe-modernization-and-data-offload/SKILL.md |
| Testing and lower environments | Contract testing, testcase patterns, data-quality tools, resiliency testing, failure drills, reconciliation, anti-patterns, synthetic data, masked lower environments, and validation-security review starter packs | references/data-quality-tooling-and-rule-management.md, starter-packs/resiliency-testing-starter.yaml |
| Language-specific engineering | Python pipeline packaging, Scala JVM data jobs, and Java integration or metadata services |
skills/python-data-engineering-and-pipeline-packaging/SKILL.md, skills/scala-data-engineering-on-jvm-runtimes/SKILL.md, skills/java-data-engineering-and-integration-services/SKILL.md |
| Adoption and automation | VS Code extension, JetBrains plugin, Kiro steering, hooks, starter packs, examples, MCP templates, and machine-readable asset registry |
docs/getting-started.md, registry/assets.json |
Lifecycle Commands
These commands are the clearest way to understand the repo. They can be mapped to slash commands, prompts, hooks, or local workflows.
| What you're doing | Command | Key principle |
|---|---|---|
| Define the data product | /spec |
Contract, SLA, lineage, schema, retention, ownership |
| Plan the work | /plan |
Small, atomic, verifiable tasks |
| Build incrementally | /build |
Safe slices over big rewrites |
| Prove publish safety | /validate |
Quality, contract compliance, and reconciliation are proof |
| Review the change | /review |
Reliability, governance, cost, and operability |
| Replay or cut over safely | /backfill |
Backfills, reruns, and cutovers need explicit guardrails |
| Ship and operate | /ship |
Safe rollout, observability, and rollback paths |
Choose Your Path
- New pipeline -> use
/spec - dbt project -> use
starter-packs/warehouse-analytics-starter.yaml - Streaming system -> use
starter-packs/streaming-reliability-starter.yaml - Production reliability and failure recovery -> use
starter-packs/production-reliability-starter.yamlandtutorials/production-reliability-and-mcp-observability.md - Serverless Spark or MSK hardening -> use
examples/aws-serverless-spark-msk-reliability/ - Streaming architecture review -> use
references/streaming-architecture-patterns.md - Cloud architecture review -> use
references/cloud-data-engineering-architecture-patterns.md - Pipeline orchestration review -> use
references/pipeline-orchestration-patterns.md - Validation and testcase review -> use
starter-packs/validation-security-review-starter.yaml - Resiliency testing -> use
starter-packs/resiliency-testing-starter.yaml Pythondata pipeline work -> usepython-data-engineering-and-pipeline-packagingScalaSpark or JVM jobs -> usescala-data-engineering-on-jvm-runtimesJavaconnectors or data services -> usejava-data-engineering-and-integration-servicesMySQLversusNoSQLchoice -> useoperational-datastore-selection-relational-and-nosql- Anti-pattern review -> use
references/data-engineering-anti-patterns.md ETLorELTmodernization -> useetl-elt-and-modernization-strategy- Partner file or
SFTPingestion -> usefile-and-partner-feed-ingestion Glue Data CatalogorLake Formationgovernance -> useglue-data-catalog-and-lake-formation-governanceUnity Cataloggovernance -> useunity-catalog-and-lakehouse-governance- Azure governance or
Purview-> usemicrosoft-purview-and-azure-data-governance DataplexorBigQuerygovernance -> usedataplex-and-bigquery-governanceSnowflake-native pipelines -> usesnowflake-native-pipelines-and-governanceBigQueryorDataformplatform work -> usebigquery-and-dataform-platform-engineering- Data-quality tool strategy -> use
data-quality-platforms-and-rule-management - Incident recovery -> use
incident-triage-and-pipeline-recovery - Disaster recovery planning -> use
data-platform-disaster-recovery-and-business-continuity - Platform operating model or golden paths -> use
data-platform-operating-model-and-service-ownership - Schema migration -> use
schema-evolution-and-contract-migrations - Cutover or backfill -> use
safe-backfill-and-replay-orchestrationanddata-migration-and-platform-cutover - CI/CD and progressive release -> use
starter-packs/data-platform-cicd-release-starter.yaml - Regional compliance or sovereignty -> use
regional-data-compliance-and-sovereignty ESGreporting -> usestarter-packs/regional-compliance-and-esg-reporting-starter.yaml- Regulated data (
PII,PCI,HIPAA) -> usedata-security-compliance-and-regulated-data - Test data or synthetic fixtures -> use
test-data-preparation-and-synthetic-data - Lower-environment masked refresh -> use
lower-environment-data-masking-and-obfuscation InformaticaorTalendestate -> useenterprise-etl-and-data-integration-modernization- Mainframe modernization -> use
mainframe-modernization-and-data-offload
Hooks
The hooks/ directory adds a lightweight operating layer:
session-start.shcontract-check-pre.shpipeline-review-pre.shincident-mode.shbackfill-guard.shschema-change-guard.shcost-check.shrelease-guard.sh
Use these hooks when you want the repository to behave more like a workflow system than a static library.
Initial Skill Pack
This repository includes 73 workflow skills plus 1 compatibility alias (using-data-agent-skills redirects to using-data-engineering-agent-skills). The alias exists for older installs; do not count it as a separate workflow.
This repository now includes a broader production-grade skill pack:
using-data-engineering-agent-skills(canonical start-here skill)using-data-agent-skills(compatibility alias — redirect only)data-specificationpipeline-planning-and-task-breakdowndata-quality-and-contract-testingdata-resiliency-testing-and-failure-injectionorchestration-and-backfillslineage-pii-and-governancedata-security-compliance-and-regulated-dataregional-data-compliance-and-sovereigntyesg-and-sustainability-regulatory-reportinglower-environment-data-masking-and-obfuscationspark-and-distributed-processingairflow-and-workflow-orchestrationstreaming-and-messaging-systemsfile-and-partner-feed-ingestionlakehouse-table-format-engineeringdata-lake-and-zone-architecturewarehouse-and-schema-designpython-data-engineering-and-pipeline-packagingscala-data-engineering-on-jvm-runtimesjava-data-engineering-and-integration-servicesoperational-datastore-selection-relational-and-nosqldata-mesh-and-domain-oriented-designdelta-lake-and-medallion-architecturedbt-and-analytics-engineeringcdc-and-incremental-loadingschema-evolution-and-contract-migrationswarehouse-performance-and-cost-optimizationdata-platform-disaster-recovery-and-business-continuitydata-observability-and-sla-managementincident-triage-and-pipeline-recoverydata-platform-operating-model-and-service-ownershipterraform-and-data-platform-infrastructuresnowflake-native-pipelines-and-governancebigquery-and-dataform-platform-engineeringsemantic-layer-and-metric-governancenotebook-to-production-hardeningdata-sharing-and-publishing-contractsdata-catalog-and-discoveryglue-data-catalog-and-lake-formation-governanceunity-catalog-and-lakehouse-governancemicrosoft-purview-and-azure-data-governancedataplex-and-bigquery-governanceprivacy-retention-and-right-to-deleteetl-elt-and-modernization-strategymainframe-modernization-and-data-offloadtest-data-preparation-and-synthetic-datareverse-etl-and-operational-data-servingfeature-store-and-ml-data-pipelinesdata-migration-and-platform-cutoverapi-and-saas-ingestion-patternssource-reliability-and-extraction-resilienceenterprise-etl-and-data-integration-modernizationdata-reconciliation-and-financial-controlsdata-platform-ci-cd-and-release-managementmaster-data-and-entity-resolutiondebezium-and-kafka-connect-cdcapache-beam-unified-batch-and-streamapache-hudi-lakehousetrino-presto-federated-queryopenmetadata-datahub-and-openlineagegreat-expectations-deequ-and-cualleedata-quality-platforms-and-rule-managementlakefs-and-data-versioningclickhouse-real-time-analyticssuperset-and-metrics-servingavro-protobuf-json-schema-registryduckdb-local-analytics-and-devdata-contract-testing-with-schema-registrysafe-backfill-and-replay-orchestrationspark-serverless-reliability-and-state-managementkafka-resilience-and-schema-evolutionmcp-data-observability-integration
Future skills can extend this pack for:
- additional platform-specific delivery patterns for tools such as
EMR,Flink,Kafka,Kinesis,Iceberg,SSIS,DataStage, andMatillion - enterprise governance overlays and automated validation hooks
Platform Presets
The core skills stay vendor-neutral. Platform-specific guidance lives in presets so agents can adapt the same workflow to the stack a team actually uses.
Current presets:
aws-data-engineeringazure-data-engineeringgcp-data-engineeringdatabricks-lakehouse-engineeringalibaba-cloud-data-engineeringsnowflake-modern-data-platforminformatica-data-integrationtalend-data-integrationmulti-cloud-hybrid-data-engineeringapache-spark-engineeringapache-flink-stream-processingapache-airflow-orchestrationapache-kafka-streamingapache-iceberg-lakehouse
Project Structure
data-engineering-agent-skills/
+-- skills/ # Workflow-driven skill definitions
+-- presets/ # Platform and stack-specific operating profiles
+-- references/ # Reusable checklists and guidance
+-- templates/ # Spec, plan, and task templates
+-- registry/ # Machine-readable asset registry and indexes
+-- hooks/ # Session-start and pre-flight automation hooks
+-- docs/ # Setup, onboarding, and format guidance
+-- vscode-extension/ # VS Code installer extension
+-- jetbrains-plugin/ # JetBrains installer plugin
+-- mcp/ # MCP configuration templates
+-- starter-packs/ # Opinionated bundles by use case
+-- agents/ # Specialist personas and review roles
+-- .claude-plugin/ # Claude plugin manifests and install bundles
+-- .kiro/ # Kiro steering adapter files
+-- .opencode/ # OpenCode integration surface
+-- CLAUDE.md # Claude-style repository entry point
`-- examples/ # Example projects and generated artifacts
Setup Guides
Agent-specific setup guides are available in docs/:
docs/getting-started.mddocs/cursor-setup.mddocs/kiro-setup.mddocs/claude-setup.mddocs/copilot-setup.mddocs/windsurf-setup.mddocs/opencode-setup.mddocs/generic-markdown-rules-setup.mddocs/codex-setup.mddocs/jetbrains-setup.md
Tutorials
Longer-form walkthroughs live in tutorials/:
tutorials/README.mdtutorials/using-data-engineering-agent-skills.mdtutorials/cloud-data-engineering-architecture-patterns.mdtutorials/pipeline-orchestration-patterns.mdtutorials/streaming-architecture-patterns.mdtutorials/data-resiliency-testing-patterns.mdtutorials/platform-native-governance-patterns.mdtutorials/partner-feed-ingestion-and-replay-safe-file-processing.mdtutorials/disaster-recovery-and-restore-drills.mdtutorials/mainframe-modernization-and-cutover.mdtutorials/data-quality-tools-and-rule-operating-model.mdtutorials/etl-elt-modernization-and-cutover.mdtutorials/regulated-data-and-compliance-workflows.mdtutorials/installing-vscode-and-jetbrains-plugins.md
VS Code Extension
The first working VS Code extension scaffold lives in vscode-extension/.
Installable release assets are published from the repository release page as .vsix downloads.
Marketplace publishing is supported through .github/workflows/publish-plugins.yml for VS Code Marketplace and Open VSX when publish secrets are configured.
Start here for the VS Code family:
vscode-extension/README.mdtutorials/installing-vscode-and-jetbrains-plugins.mddocs/plugin-publishing.md- latest release downloads
It provides command-palette installers for:
- the full toolkit
- the core pack
- agent adapters
- starter packs
- MCP templates
- runnable examples
It is intended for the VS Code family:
VS CodeCursorWindsurfVSCodium
JetBrains Plugin
Install from JetBrains Marketplace — search "Data Engineering Agent Skills" in your IDE's plugin settings.
The plugin source lives in jetbrains-plugin/.
Start here for JetBrains IDEs:
- JetBrains Marketplace listing
jetbrains-plugin/README.mddocs/jetbrains-setup.mdtutorials/installing-vscode-and-jetbrains-plugins.mddocs/plugin-publishing.md- latest release downloads
It targets IntelliJ-platform IDEs such as:
IntelliJ IDEAPyCharmWebStormDataGripGoLandPhpStorm
Multi-Agent Packaging
Native adapters are included for multiple agent ecosystems:
.cursor/rules/.claude/commands/.claude-plugin/.gemini/commands/.kiro/steering/.github/copilot-instructions.mdAGENTS.mdCLAUDE.md.opencode/.windsurfrules.example
Direct setup links for common agent surfaces:
Claude->docs/claude-setup.mdCursor->docs/cursor-setup.mdCopilot->docs/copilot-setup.mdKiro->docs/kiro-setup.mdOpenCode->docs/opencode-setup.mdWindsurf->docs/windsurf-setup.mdCodex->docs/codex-setup.md- generic
AGENTS.mdsetup ->docs/getting-started.md
Install Scripts
Installation helpers are available in scripts/:
scripts/install.sh --tool cursor|claude|copilot|gemini|kiro|windsurf|opencode|generic|all --target <path>scripts/install.ps1 --tool cursor|claude|copilot|gemini|kiro|windsurf|opencode|generic|all --target <path>scripts/install.sh --tool codex --target <path>scripts/install_toolkit.pyscripts/hook_runner.pyscripts/validate-skills.pyscripts/validate-assets.pyscripts/validate_dataset_contract.pyscripts/check-links.pyscripts/test-plugin-installation.pyrequirements.txtrequirements-proof.txtscripts/sync-rules.shscripts/sync-rules.ps1
Workflow Automation
Repository automation includes:
.github/workflows/validate-and-package.yml.github/workflows/test-plugin-installation.yml.github/workflows/proof-assets.yml.github/workflows/agent-benchmarks.yml.github/workflows/release-artifacts.yml.github/workflows/publish-plugins.yml.github/workflows/markdown-lint.yml
Machine-Readable Templates
Starter contract and response templates are available in templates/:
source-contract.yamldataset-contract.yamlmetric-contract.yamldata-compliance-controls.yamlbackfill-plan.yamlschema-change-plan.yamlrelease-gate-evidence.yamlincident-runbook.md
Asset Registry
Machine-readable discovery lives in:
registry/assets.json
Use it to index templates, starter packs, examples, MCP templates, agent adapters, and installer bundle contents without scraping the Markdown docs.
For human-readable selection of checklists and decision guides, start with:
references/README.md
MCP Config Templates
Template MCP configs are available in mcp/ for:
- GitHub
- Postgres
- Snowflake
- BigQuery
- Databricks
- dbt Cloud
- Airflow
- Kafka
- Spark
- Terraform
- Slack and Jira incident flows
Each template is a starting point only. Use mcp/README.md for environment-variable requirements and service-specific setup notes before connecting a live system.
End-To-End Examples
The repository includes 14 example packs in examples/:
| Type | Count | What you get |
|---|---|---|
| Runnable scaffold | 5 | Local proof paths (Makefile, scripts, contract validation, smoke tests) |
| Architecture blueprint | 9 | README.md, spec.md, plan.md, tasks.md — delivery shape without executable code |
See examples/README.md for the full selector table.
Runnable scaffolds (5)
aws-s3-glue-athena-icebergdatabricks-delta-medalliondbt-warehouse-martskafka-flink-streamingaws-serverless-spark-msk-reliability
Run make smoke-test inside each directory (or follow the README commands on Windows).
Architecture blueprints (9)
api-saas-to-warehouse-ingestiongcp-pubsub-dataflow-bigquerysnowflake-dbt-reverse-etlprivacy-retention-deletion-workflowfeature-store-online-offline-paritymulti-cloud-warehouse-cutoverdata-platform-cicd-progressive-releaseesg-regulatory-reporting-foundationvalidation-and-security-review-foundation
Use blueprints for agent planning and /spec → /plan workflows. Use runnable scaffolds when you need executable proof.
Starter Packs
Use the starter packs in starter-packs/ to adopt the repository by problem area:
aws-lakehouse-starter.yamldatabricks-medallion-starter.yamlwarehouse-analytics-starter.yamlstreaming-reliability-starter.yamlprivacy-governance-starter.yamlregulated-data-compliance-starter.yamldata-platform-cicd-release-starter.yamlvalidation-security-review-starter.yamlregional-compliance-and-esg-reporting-starter.yamltest-data-lower-environments-starter.yamlenterprise-etl-modernization-starter.yamlresiliency-testing-starter.yamlproduction-reliability-starter.yaml
Skills Catalog
See skills-index.md for a grouped catalog by lifecycle and platform.
Agent Personas
Pre-configured specialist personas give targeted review perspectives for data engineering work:
| Agent | Role | Best for |
|---|---|---|
data-architect |
Architecture reviewer | Platform shape, contracts, ownership, replay, and recovery design |
analytics-engineer-reviewer |
Analytics reviewer | dbt, marts, semantic consistency, and model grain |
data-platform-reliability-reviewer |
Reliability reviewer | SLAs, incidents, backfills, replay safety, and operational readiness |
data-platform-infrastructure-reviewer |
Infrastructure reviewer | Terraform, environment boundaries, secrets, and access controls |
data-security-and-compliance-auditor |
Security and compliance reviewer | PII, PCI, HIPAA, lineage, audit evidence, retention, and publish controls |
Use personas mainly for /review, /validate, and /ship when you want one focused lens on the current change.
Reference Guides
Use references/ for high-signal checklists and workflow support material.
| Reference | Covers |
|---|---|
references/README.md |
Human-readable selector for architecture, testing, compliance, ingestion, and operating-model checklists |
references/data-testing-patterns.md |
Contract tests, reconciliation, freshness, replay, and publish-proof patterns |
references/data-resiliency-testing-patterns.md |
Failure drills for restart, outage, replay, checkpoint recovery, backlog catch-up, and publish protection |
references/platform-native-governance-patterns.md |
Cloud-native governance choices across Glue Data Catalog, Lake Formation, Unity Catalog, Purview, and Dataplex |
references/data-platform-dr-bcp-checklist.md |
Recovery objectives, dependency inventory, failover choices, restore validation, and drill readiness |
references/data-platform-operating-model-checklist.md |
Service catalog, ownership, golden paths, support boundaries, and lifecycle flows for shared data platforms |
references/mainframe-modernization-checklist.md |
Mainframe source inventory, copybook mapping, batch-window behavior, reconciliation, coexistence, and cutover controls |
references/data-quality-tooling-and-rule-management.md |
Rule ownership, severity, tool boundaries, and operating-model choices for multi-tool data-quality programs |
references/file-ingestion-checklist.md |
Partner-feed contracts, landing, validation, duplicate handling, replay, and publish protection for file-based ingestion |
references/data-validation-and-testcase-patterns.md |
Concrete testcase categories for schema, nulls, duplicates, replay, security, skew, and late-data behavior |
references/data-platform-security-checklist.md |
Access, secrets, environment boundaries, auditability, and operational safety |
references/data-engineering-anti-patterns.md |
Common failure modes across validation, storage, pipelines, governance, and operations plus healthier counter-patterns |
references/security-compliance-regulated-data-checklist.md |
PII, PCI, HIPAA, lineage, retention, deletion, and release-gate evidence |
references/etl-elt-modernization-checklist.md |
Choosing ETL versus ELT boundaries, modernization sequencing, parity checks, and retirement of old paths |
references/progressive-data-release-patterns.md |
Shadow validation, canary publish, dual-run, consumer cutover, and rollback-window patterns for data releases |
references/test-data-preparation-checklist.md |
Safe synthetic data, masked fixtures, realism levels, and lower-environment validation coverage |
references/lower-environment-masking-checklist.md |
Non-production refresh boundaries, masking controls, auditability, and retained usability |
references/enterprise-etl-modernization-checklist.md |
Mapping discovery, parameterization, scheduler dependencies, and migration parity for Informatica, Talend, and similar ETL stacks |
references/regional-compliance-and-data-sovereignty-checklist.md |
Multi-country residency, transfer, jurisdiction overlays, and region-specific engineering controls including Europe, USA, India, and Saudi Arabia |
references/esg-and-sustainability-reporting-checklist.md |
Scope, methodology, assurance-readiness, and KPI traceability for CSRD, ESRS, BRSR, and similar sustainability reporting workflows |
references/streaming-architecture-patterns.md |
Event backbone, CDC/outbox, replay-safe sinks, DLQ, event-time, joins, savepoints, and hot-partition containment |
references/cloud-data-engineering-architecture-patterns.md |
Common lake, warehouse, lakehouse, streaming, and hybrid architecture patterns across AWS, Azure, GCP, Databricks, Snowflake, and Alibaba Cloud |
references/pipeline-orchestration-patterns.md |
Generic orchestration decisions plus AWS, Azure, GCP, and Databricks workflow patterns and best practices |
references/orchestration-patterns.md |
How skills, personas, commands, and hooks in this repository should compose without overlap |
references/spark-serverless-reliability-patterns.md |
Staging, checkpoints, timeout rollback, and orphan cleanup for serverless Spark |
references/kafka-production-guardrails.md |
Producer durability, schema evolution, DLQ, and lag/replay guardrails for Kafka |
references/mcp-data-observability-patterns.md |
Symptom-to-MCP mapping for live lag, Spark plans, and run-state diagnosis |
How This Toolkit Works
The repository is intentionally layered so agents do not confuse workflow, perspective, and entry point:
| Layer | What it is | Example | Job |
|---|---|---|---|
| Skill | Workflow with steps and exit criteria | data-specification |
The process the agent should follow |
| Preset | Platform mapping and design rules | aws-data-engineering |
The stack-specific adaptation layer |
| Persona | Specialized review perspective | data-platform-reliability-reviewer |
The point of view applied durin |
No comments yet
Be the first to share your take.