workflow-management

Manage and troubleshoot Treasure Data workflow runs with Digdag pipelines.

21|24|Updated Oct 21, 2025
One-click install
npx skills add https://github.com/treasure-data/td-skills --skill workflow-management
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: workflow-management
Source: https://github.com/treasure-data/td-skills/tree/main/workflow-skills/management
Command: npx skills add https://github.com/treasure-data/td-skills --skill workflow-management

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill provides expert assistance for managing, debugging, monitoring, and optimizing Treasure Data workflows (Digdag pipelines). It helps users quickly identify and resolve failures, improve performance, and implement best practices for reliable data operations, reducing downtime and operational complexity.

Core Features & Use Cases

  • Debugging & Troubleshooting: Guides on investigating failed sessions, checking logs, and identifying root causes for common workflow errors, accelerating problem resolution.
  • Performance Optimization: Offers strategies for optimizing slow queries, managing resource limits, and improving overall workflow execution speed, saving compute costs and time.
  • Alerting & Monitoring: Provides patterns for setting up notifications (Slack, email) on workflow failures and implementing data quality checks, ensuring proactive issue detection.
  • Use Case: A critical daily ETL workflow fails unexpectedly. This skill guides the user through checking session logs, identifying a slow query, and implementing a retry mechanism with alerts, ensuring the data pipeline is quickly restored and future failures are proactively managed.

Quick Start

Check recent workflow failures

digdag sessions <workflow_name> --failed --last 20

View logs for a specific failed session and task

digdag log <session_id> +task_name

Frequently Asked Questions about workflow-management

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

FAQPage Schema
How do I debug a failed Treasure Data workflow?

Debugging a failed TD workflow involves checking session logs with `digdag log <session_id>` to identify the root cause, examining task-level errors, and reviewing slow queries or resource issues. The Skill guides you through log analysis, common failure patterns, and targeted fixes to restore your pipeline quickly.

What's the best way to monitor Digdag pipeline failures and set up alerts?

Monitor Digdag pipelines by tracking session status, implementing alerting patterns via Slack or email on failures, and setting up data quality checks across projects. This Skill provides pre-built notification templates and monitoring patterns to catch issues before they impact downstream processes.

How do I retry or backfill failed workflow runs in Treasure Data?

Retry and backfill patterns in TD workflows let you rerun failed sessions or fill historical data gaps with controlled execution. This Skill covers structured retry logic, backfill strategies, and session management to ensure reliable recovery without duplicating valid data.

Can I implement data quality checks within my Digdag ETL pipeline?

Yes, data quality validation integrates into Digdag pipelines through SQL queries and predefined checks within workflow definitions. This Skill provides patterns for embedding quality gates that flag anomalies, validate row counts, and enforce schema constraints across pipeline stages.

Why is my ETL workflow slow, and how do I optimize it?

Slow ETL workflows often stem from unoptimized queries, resource contention, or inefficient task sequencing. This Skill offers strategies for identifying bottlenecks in logs, optimizing query performance, managing resource limits, and improving overall pipeline execution speed to reduce costs and time.