data-engineering

Automate data pipeline design, orchestration, and quality checks across Airflow, Dagster, and Prefect.

14|1|Updated May 6, 2026
One-click install
npx skills add https://github.com/wzyxdwll/ccgx-workflow --skill data-engineering-wzyxdwll
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: data-engineering
Source: https://github.com/wzyxdwll/ccgx-workflow/tree/main/templates/skills/domains/data-engineering
Command: npx skills add https://github.com/wzyxdwll/ccgx-workflow --skill data-engineering-wzyxdwll

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Data engineering teams often struggle to design, schedule, monitor, and ensure the quality of complex data pipelines across multiple frameworks. This skill provides guidance to standardize orchestration, data quality gates, and lineage across Airflow, Dagster, and Prefect, enabling reliable data delivery.

Core Features & Use Cases

  • Unified orchestration across Airflow, Dagster, and Prefect.
  • Data quality checks with tools like Great Expectations, dbt, and Soda Core.
  • Support for both batch and streaming pipelines and data lineage tracking.
  • Best-practice guidance for testing, observability, and maintainable pipelines.
  • Use Case: Design a robust pipeline that ingests events from Kafka, processes them with Spark, and validates results before landing in a warehouse.

Quick Start

Create an initial data pipeline skeleton by selecting a framework and wiring in a simple batch job with validation.

Frequently Asked Questions about data-engineering

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

FAQPage Schema
How do I orchestrate data pipelines with quality checks across Airflow, Dagster, and Prefect?

You can orchestrate data pipelines with quality checks by applying standardized guidance for Airflow, Dagster, and Prefect, enabling reliable data delivery through unified scheduling, data quality gates, and lineage tracking.

What is the best way to add data quality gates to streaming pipelines?

The best way to add data quality gates to streaming pipelines is by integrating validation tools like Great Expectations, dbt, and Soda Core, ensuring results are validated before landing in a warehouse.

Can I use this approach for both batch and streaming workloads?

Yes, this approach supports both batch and streaming workloads, providing framework-agnostic orchestration guidance to build and maintain reliable pipelines across modern tooling.

How do I design a batch job with validation in a new data pipeline?

You design a batch job with validation by creating an initial pipeline skeleton, selecting an orchestration framework, and wiring in the batch job with data quality checks to enforce validation.

Does this guidance include best practices for testing and observability in data engineering?

Yes, this guidance includes best practices for testing and observability in data engineering, ensuring your pipelines are maintainable, observable, and reliable across the orchestrated workflows.

How do I track data lineage in pipelines built with Airflow or Dagster?

You track data lineage in pipelines built with Airflow or Dagster by applying standardized orchestration guidance that supports lineage tracking alongside data quality enforcement and observability.