data-pipeline

Design and operate ETL/ELT pipelines with Apache Spark, Airflow, and dbt.

4|1|Updated Mar 3, 2026
One-click install
npx skills add https://github.com/aegntic/clawreform --skill data-pipeline-aegntic
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: data-pipeline
Source: https://github.com/aegntic/clawreform/tree/main/crates/clawreform-skills/bundled/data-pipeline
Command: npx skills add https://github.com/aegntic/clawreform --skill data-pipeline-aegntic

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill provides expert guidance on designing, building, and operating reliable, observable, and scalable data pipelines for ETL/ELT processes.

Core Features & Use Cases

  • ETL/ELT Design: Offers best practices for data loading and transformation strategies.
  • Orchestration: Provides insights into using tools like Apache Airflow for DAG management.
  • Data Quality: Emphasizes implementing data quality checks and validation.
  • Use Case: A data engineer needs to set up a new daily data ingestion process from a transactional database to a data warehouse, ensuring data integrity and efficient processing.

Quick Start

Use the data-pipeline skill to design an Airflow DAG for an incremental data load.

Frequently Asked Questions about data-pipeline

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

FAQPage Schema
How do I build a reliable ETL data pipeline with Airflow and dbt?

To build a reliable ETL data pipeline with Airflow and dbt, you should design DAGs for orchestration and use dbt for transformations, ensuring idempotent data loads and robust data quality checks.

What's the best way to implement data quality checks in an ELT pipeline?

The best way to implement data quality checks in an ELT pipeline is to integrate validation steps directly into your dbt transformations and Airflow DAGs to monitor data integrity and ensure reliable processing.

How does Apache Spark work with Airflow for scalable batch processing?

Apache Spark works with Airflow for scalable batch processing by using Airflow DAGs to schedule and trigger Spark jobs, enabling reliable and observable data ingestion from transactional databases to your warehouse.

Do I need Apache Airflow to orchestrate incremental data loads?

You need Apache Airflow to orchestrate incremental data loads because it provides the DAG management required to schedule daily ingestion processes, ensuring data integrity and efficient processing.

Can I use this approach for both batch and streaming data architectures?

Yes, you can use this approach for both batch and streaming data architectures, as the guidance covers designing scalable pipelines that support reliable and observable data workflows across both processing paradigms.

Why does my dbt transformation fail during daily data ingestion?

Your dbt transformation may fail during daily data ingestion if idempotency is not enforced, meaning previous pipeline runs interfere with current loads and compromise data quality and integrity.