data-engineering

Reviews and designs batch/streaming data engineering changes for correctness and contract compliance.

15|2|Updated Dec 13, 2025
One-click install
npx skills add https://github.com/d-padmanabhan/agent-engineering-handbook --skill data-engineering-d-padmanabhan
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: data-engineering
Source: https://github.com/d-padmanabhan/agent-engineering-handbook/tree/main/skills/data-engineering
Command: npx skills add https://github.com/d-padmanabhan/agent-engineering-handbook --skill data-engineering-d-padmanabhan

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

This Skill helps you design and review batch and streaming data engineering workflows so they are correct, contract-compliant, safe to backfill, secure for sensitive data, and observable for production operations.

Core Features & Use Cases

  • PR review workflow: provides a structured checklist for correctness, data loss/duplication risk, security/PII exposure, and performance/operational gaps.
  • Design workflow for new datasets/pipelines: guides you through inputs, explicit data contracts (schema + semantics + SLA), processing choices (batch vs streaming, watermark/offset tracking), outputs/layering, quality gates, security controls, operational runbooks for backfills, and cost awareness.
  • Platform-specific rule pointers: targets the most relevant guidance for Databricks, Snowflake, Kafka/Confluent, and Teradata, aligned with broader SQL/data engineering rules.

Quick Start

Use the data-engineering skill to review a pull request by comparing main..HEAD changes and then assess the diff for contract breaks, idempotency/backfill safety, observability gaps, and security/PII risks.

Frequently Asked Questions about data-engineering

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

FAQPage Schema
How do I review data engineering pull requests for contract breaks and idempotency?

To review data engineering pull requests, compare main..HEAD changes to assess the diff for contract breaks, idempotency, backfill safety, observability gaps, and security/PII risks. This structured checklist ensures correctness and safe operations across pipeline changes.

What is the best way to design streaming pipelines with data contracts for Snowflake or Databricks?

Designing streaming pipelines with data contracts requires defining explicit schema, semantics, and SLAs, alongside processing choices like watermark or offset tracking. This approach guides inputs, quality gates, and operational runbooks for lakehouse and warehouse workflows.

How do I plan safe backfills and replays for ETL pipelines?

Planning safe backfills and replays for ETL pipelines requires ensuring idempotency and cost-aware incremental processing. The design workflow evaluates operational runbooks, data loss or duplication risks, and replay strategies to maintain production safety during pipeline updates.

Does this data pipeline review process work with Confluent Kafka and Teradata?

Yes, the data pipeline review process works with Confluent Kafka and Teradata, alongside Databricks and Snowflake. It applies platform-specific rule pointers to target the most relevant guidance for ETL/ELT and streaming workflows across these specific environments.

When do I need observability instrumentation and governance controls in ETL workflows?

Observability instrumentation and governance controls in ETL workflows are needed to satisfy production operations and least privilege requirements. Applying these controls during pipeline design prevents security or PII exposure and ensures continuous operational monitoring.

Why does my batch processing pipeline lack contract-driven semantics and quality gates?

Batch processing pipelines lack contract-driven semantics and quality gates when design workflows skip explicit schema, SLA, and semantic definitions. Implementing these gates ensures correctness, prevents data loss, and validates processing choices before lakehouse deployment.