airflow-workflow

Manage Apache Airflow scheduled SQL job lifecycles with validated configurations.

1.5k|222|Updated Jul 4, 2025
One-click install
npx skills add https://github.com/Datus-ai/Datus-agent --skill airflow-workflow
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: airflow-workflow
Source: https://github.com/Datus-ai/Datus-agent/tree/main/datus/resources/skills/airflow-workflow
Command: npx skills add https://github.com/Datus-ai/Datus-agent --skill airflow-workflow

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Data engineering teams face challenges managing Apache Airflow scheduled SQL jobs, including troubleshooting failed runs without structured guidance, safely updating job configurations without disrupting active workflows, and adhering to connection and naming conventions to avoid costly misconfigurations and downtime.

Core Features & Use Cases

  • Full Job Lifecycle Management: Safely create, update, pause, resume, and delete Airflow scheduled SQL jobs with built-in guardrails to prevent accidental data loss or unplanned downtime.
  • Structured Troubleshooting Workflow: Step-by-step guidance to diagnose failed job runs, identify common failure causes (SQL syntax errors, connection failures, timeouts, permission issues), and implement validated fixes.
  • Best Practice Enforcement: Built-in naming conventions for jobs and SQL files, plus a reference of common cron expressions to ensure consistent, maintainable workflow scheduling.
  • Real-World Use Case: A data engineer needs to resolve a failing daily sales summary job that is throwing a connection error; this skill guides them to verify the correct conn_id in Airflow Connections, update the job configuration, and run a manual test to confirm the fix works.

Quick Start

Use the airflow-workflow skill to troubleshoot and resolve the failed hourly_order_count Airflow job that is throwing a permission denied error.

Frequently Asked Questions about airflow-workflow

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

FAQPage Schema
How do I troubleshoot a failed Apache Airflow scheduled SQL job?

To troubleshoot a failed Apache Airflow scheduled SQL job, follow structured steps to diagnose common causes like SQL syntax errors, connection failures, timeouts, and permission issues, then apply validated fixes to resume the workflow.

What is the best way to update Airflow job configurations without causing downtime?

The best way to update Airflow job configurations safely is by using built-in guardrails for job lifecycle management that validate modifications, preventing accidental data loss and unplanned downtime during active data engineering workflows.

How do you configure database connections for Airflow SQL jobs using conn_id?

Configuring database connections for Airflow SQL jobs requires verifying the correct conn_id in Airflow Connections to ensure the scheduled data tasks can authenticate and execute queries against the target database successfully.

How do I schedule recurring data tasks in Airflow using cron expressions?

Scheduling recurring data tasks in Airflow uses standard cron expressions to define execution intervals, enforcing workflow scheduling best practices and consistent naming conventions for maintainable job lifecycle management.

Why does my Airflow job fail with a permission denied error on a daily summary task?

An Airflow job fails with a permission denied error when database credentials lack execution rights; resolve it by verifying the conn_id connection configuration, updating permissions, and running a manual test to confirm the fix.

What naming conventions should I follow for Airflow jobs and SQL files?

Following naming conventions for Airflow jobs and SQL files ensures consistent, maintainable workflow scheduling by standardizing identifiers across the job lifecycle, reducing misconfigurations and troubleshooting overhead.