dagster-pipelines

Implement Dagster pipeline architectures with asset factories, ops, and resources.

9|2|Updated Nov 29, 2024
One-click install
npx skills add https://github.com/bbvch-ai/aihub-core --skill dagster-pipelines
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: dagster-pipelines
Source: https://github.com/bbvch-ai/aihub-core/tree/main/.claude/skills/dagster-pipelines
Command: npx skills add https://github.com/bbvch-ai/aihub-core --skill dagster-pipelines

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill eliminates the steep learning curve and common pitfalls of building production-grade Dagster pipelines, which require mastering asset-centric architecture, dynamic partitions, automation conditions, and integrated resource configurations for data and AI workloads.

Core Features & Use Cases

  • Complete Dagster Component Reference: Covers asset factories, ops, resources, IO managers, sensors, schedules, and automation conditions with implementation examples and best practices.
  • Pre-built Pipeline Patterns: Includes factory functions for two-stage document processing pipelines (SharePoint to S3 to vector store) and configurable Definitions for common data ingestion and RAG workflows.
  • Use Case: A data engineering team building a knowledge base pipeline can use this Skill to correctly implement observable assets that detect new document uploads, auto-materialize embedding assets, and configure Milvus IO managers for vector storage.

Quick Start

Use the dagster-pipelines skill to set up an observable asset that automatically triggers downstream processing when new documents are added to your S3 data lake.

Frequently Asked Questions about dagster-pipelines

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

FAQPage Schema
How do I build a production-ready Dagster pipeline for data ingestion?

Building a production-ready Dagster pipeline requires asset-centric architecture, dynamic partitions, and configured resources. This Skill provides reference implementations with retry logic and partition management to ensure robust data ingestion.

What is the best way to trigger downstream processing when new documents are uploaded to S3?

Triggering downstream processing for new S3 documents requires observable assets using content-hash tracking. This Skill provides reference implementations to detect new uploads and automatically materialize downstream embedding assets for RAG workflows.

How do I configure an IO manager for vector storage in Dagster?

Configuring an IO manager for vector storage in Dagster involves defining resources for your vector database. This Skill includes pre-built patterns for Milvus IO managers to handle vector embeddings within your knowledge base workflows.

Can I use asset factories to automate Dagster pipeline creation for multiple data sources?

Yes, you can use asset factories to automate Dagster pipeline creation for multiple data sources. This Skill provides factory functions for two-stage document processing pipelines, enabling configurable definitions for common data ingestion workflows.

Does Dagster support sensors and automation conditions for auto-materializing assets?

Dagster supports sensors and automation conditions for auto-materializing assets based on external events. This Skill covers implementation examples and best practices for configuring these automation patterns within your data orchestration workflows.