aspyn-dag-patterns

Build Airflow DAGs with Aspyn client, error handling, and batch operations.

Updated Aug 23, 2026
One-click install
npx skills add https://github.com/mporenta/airflow --skill aspyn-dag-patterns
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: aspyn-dag-patterns
Source: https://github.com/mporenta/airflow/tree/main/.claude/skills/aspyn-dag-patterns
Command: npx skills add https://github.com/mporenta/airflow --skill aspyn-dag-patterns

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Airflow DAGs often need to interact with Aspyn services; this guide provides a ready-to-use pattern for authenticating, performing CRUD operations, batch processing, and validating data models with proper error handling and health checks. Use on every DAG containing aspyn in the directory name (e.g., /dags/aspyn).

Core Features & Use Cases

  • Basic client usage with clear error handling and health checks.
  • Batch processing patterns for large-scale operations with idempotency and exponential backoff.
  • Health checks and typed exceptions to ensure robust production-grade DAGs across internal Aspyn services.

Quick Start

Import the AspynClient and AspynErrorHandler, wrap tasks with the error handler, and run a minimal, idempotent Aspyn operation inside a context-managed client.

Frequently Asked Questions about aspyn-dag-patterns

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

FAQPage Schema
How do I build Airflow DAGs that integrate with Aspyn services?

Build Airflow DAGs integrating with Aspyn by importing AspynClient and AspynErrorHandler, wrapping tasks with the handler, and executing idempotent operations inside a context-managed client for reliable production workflows.

What is the best way to handle batch processing in Airflow DAGs for Aspyn?

Handle batch processing in Airflow DAGs for Aspyn by enforcing idempotent batch calls combined with exponential backoff, ensuring safe retries and reliable large-scale operations across internal services.

How do you implement error handling and health checks for Aspyn Airflow DAGs?

Implement error handling and health checks for Aspyn Airflow DAGs by utilizing typed exceptions and built-in health check patterns, ensuring robust production-grade execution and safe defaults across internal Aspyn services.

Does the Aspyn Airflow DAG pattern support environment handling and authentication?

Yes, the Aspyn Airflow DAG pattern supports environment handling and authentication, providing a ready-made client that manages credentials and enforces safe defaults for secure internal service connections.

Can I perform CRUD operations with Aspyn client inside Airflow tasks?

Yes, you can perform CRUD operations with the Aspyn client inside Airflow tasks, using provided patterns for data model validation and context-managed authentication to execute reliable database interactions.