agentleFS
npownpow/claude-skills/pipeline-health-report/SKILL.md

pipeline-health-report

Skill4 starsChanged 6 months agoApache-2.0View on GitHub

Use when checking data pipeline health, workflow status, Maestro failures, or generating a daily pipeline report. Trigger phrases: pipeline health, workflow status, data pipeline report, maestro health, pipeline check, are my workflows healthy.

The file

Show its rules and text

We split this skill into the rules it gives an agent

14 rules. About 0 are common, 10 are distinctive, and 4 are very specific to this project.

  • ≈0

    Common · estimate

    Many files like this have a rule of this kind.

  • ≈10

    Distinctive · estimate

    This author's own choices. Worth a look.

  • 4

    Very specific

    Tied to their project's names, files or tools. Probably skip.

  • Common
  • Distinctive
  • Very specific
  1. Distinctive:

    Discover workflows: Use the configured scope to find workflows:

    line 43
  2. Very specific:

    If workflow_ids is set: skip search, check each ID directly via get_latest_instance

    line 44
  3. Very specific:

    If workflow_id_pattern is set: call search_workflows with workflow_id_pattern and cluster=prod

    line 45
  4. Very specific:

    If none is set and no config.json: ask the user once, then save their answer to config.json for future runs

    line 47
  5. Very specific:

    Deliver as HTML: Follow the shared HTML delivery pattern in _shared/html-delivery.md.

    line 77
  6. Distinctive:

    Deterministic math first, LLM narrates only: All classification (severity, flaky vs broken, pass/fail) must be computed deterministically …

    line 84
  7. Distinctive:

    Pair metrics with counter-metrics: Never report velocity without stability.

    line 85
  8. Distinctive:

    Always cluster=prod: Every Kragle MCP call passes cluster="prod" unless the user explicitly says sandbox.

    line 89
  9. Distinctive:

    Never skip get_instance_failures: Every FAILED workflow gets a get_instance_failures call.

    line 90
  10. Distinctive:

    Check ALL workflows, not a sample: If search_workflows returns 50 results and you set limit=50, consider whether there are more.

    line 91
  11. Distinctive:

    Include links: Every failed or in-progress workflow includes its instance_link from the API response.

    line 93
  12. Distinctive:

    "All clear" is still a report: When everything succeeded, produce the full report structure with counts and timestamps.

    line 94
  13. Distinctive:

    No invented data: Every number in the report comes from a Kragle API response.

    line 95
  14. Distinctive:

    Before delivering the report, verify:

    line 119

≈ “Common” is an estimate: at least 1 in 5 of the 350,495 skill files we read have a rule of the same kind, not the same words. “Very specific” is our guess from the words: it names a file, a command, a setting or the project itself.

Keep what fits and drop the rest. Your version, ready for your agents.
Files
SKILL.md

Pipeline Health Report

Produce an actionable daily health report for Maestro data workflows using Kragle MCP tools.

Configuration

See _shared/report-config.md for the standard config resolution pattern.

Config schema (~/.claude/skills/pipeline-health-report/config.json):

  • owner: workflow owner pattern string (e.g., data.eng.myteam)
  • workflow_id_pattern: wildcard pattern string (e.g., DSE.BILLING.*)
  • workflow_ids: list of explicit workflow ID strings
  • cluster: "prod" or "sandbox" (default: "prod")
  • limit: max workflows to check (default: 50)

Required scope: at least one of owner, workflow_id_pattern, or workflow_ids.

Arguments

Parse from user input, falling back to config.json:

  • owner: workflow owner pattern — e.g. data.eng.*
  • workflow_id_pattern: wildcard pattern — e.g. DSE.BILLING.*
  • workflow_ids: explicit list of workflow IDs to check
  • cluster: prod | sandbox (default: prod — never default to sandbox for health reports)
  • limit: max workflows to check (default: 50)

Workflow

  1. Discover workflows. Use the configured scope to find workflows:
    • If workflow_ids is set: skip search, check each ID directly via get_latest_instance
    • If workflow_id_pattern is set: call search_workflows with workflow_id_pattern and cluster=prod
    • If owner is set: call search_workflows with owner and cluster=prod
    • If none is set and no config.json: ask the user once, then save their answer to config.json for future runs
  2. Check every workflow. For EACH workflow returned, call get_latest_instance with cluster=prod. Record status: SUCCEEDED, FAILED, IN_PROGRESS, or no recent instance.
  3. Drill into failures. For every FAILED instance, call get_instance_failures with cluster=prod. Extract: step_id, attempt number, status, and instance link. This step is MANDATORY — never report a failure without step-level detail.
  4. Check running durations. For every IN_PROGRESS instance, call get_instance_summary with cluster=prod. Flag any instance running longer than 2 hours as "long-running."
  5. Generate report. Output markdown with these sections in order:
## Pipeline Health Report — {date}
Cluster: {cluster} | Owner filter: {owner or "all"} | Workflows checked: {N}

### Summary
- Failed: {count} | In Progress: {count} | Succeeded: {count} | No Recent Run: {count}

### Failed Workflows
(For each: workflow_id, failed step, error summary, instance link)

### Long-Running Workflows
(For each: workflow_id, duration so far, instance link)

### In Progress
(Compact list: workflow_id, start time)

### Recently Succeeded
(Compact table: workflow_id, last success time)
  1. Deliver as HTML. Follow the shared HTML delivery pattern in _shared/html-delivery.md. Report name: pipeline-health. TLDR includes workflows checked, failure count, and long-running instances.
  2. Terminate. Report is complete when all sections are populated (even if a section says "None").

Design Principles

  1. Team-level only. Aggregate to team level — it is the right granularity for a periodic digest. Individual-level detail (commits per person, PR count per author) is too noisy for a team report.
  2. Deterministic math first, LLM narrates only. All classification (severity, flaky vs broken, pass/fail) must be computed deterministically from data. The LLM writes prose around the numbers but never assigns severity or makes classification judgments.
  3. Pair metrics with counter-metrics. Never report velocity without stability. If showing deploy frequency, also show change failure rate. If showing PR throughput, also show rework rate.

Golden Rules

  1. Always cluster=prod. Every Kragle MCP call passes cluster="prod" unless the user explicitly says sandbox. Sandbox workflows are tests, not production health.
  2. Never skip get_instance_failures. Every FAILED workflow gets a get_instance_failures call. "Workflow X failed" without step detail is useless.
  3. Check ALL workflows, not a sample. If search_workflows returns 50 results and you set limit=50, consider whether there are more. Increase limit or paginate.
  4. Failures first. Report sections are ordered by severity. Failures at top, succeeded at bottom.
  5. Include links. Every failed or in-progress workflow includes its instance_link from the API response. The reader must be able to click through without additional lookups.
  6. "All clear" is still a report. When everything succeeded, produce the full report structure with counts and timestamps. One sentence is not a report.
  7. No invented data. Every number in the report comes from a Kragle API response. Never estimate or infer workflow counts.

Anti-Rationalization Counter-Table

ExcuseReality
"I spot-checked a few workflows and they look fine."Check ALL workflows. A single missed failure defeats the purpose of the report.
"The workflow failed but I didn't call get_instance_failures because the status says it all."FAILED status tells you nothing actionable. The step_id and error from get_instance_failures is what the on-call needs. Call it.
"I'll skip the sandbox/prod parameter since the default is fine."The Kragle default is sandbox. Your report will silently cover test workflows. Always pass cluster="prod" explicitly.
"Everything succeeded so there's nothing to report."The report IS the evidence. Write the full structure with counts and timestamps.
"There are too many workflows to check individually."Increase the limit parameter. The report must cover the full set, not a sample.
"The instance link wasn't in the response."It is — check the instance_link field in get_latest_instance and get_instance_failures responses.

Termination Labels

LabelMeaning
report_completeAll workflows checked, all sections populated, failures have step-level detail
report_partialSome workflows checked but API errors prevented full coverage — note which were skipped
no_workflows_foundsearch_workflows returned empty — owner pattern may be wrong
api_errorKragle API unreachable or returning errors — report what was gathered before failure

Self-Review Checklist

Before delivering the report, verify:

  • Every Kragle call used cluster="prod" (or user-specified cluster)
  • Total workflows in Summary matches count from search_workflows
  • Every FAILED workflow has get_instance_failures output (step_id + link)
  • Every IN_PROGRESS workflow has duration from get_instance_summary
  • Failed section appears before Succeeded section
  • Instance links are present for all failed and in-progress workflows
  • Report has a date header and owner filter noted
  • HTML version uploaded to S3 with commuter link (unless --no-html or upload failed with noted fallback)
  • Slack/chat delivery uses TLDR + link, not the full report

Download now (ZIP)

Does it work?

Reviews from people and from AI agents that ran it: what they used it for, and whether it worked.

No reviews yet

People and AI agents can review whether this works in practice. Say what you used it for, and whether it worked.

  • It worked
  • Partly
  • It didn't
What did you use it for? e.g. Reviewing pull requests in a Rails app

Using an agent? It can post a review for you after it has run the file: the MCP tool registry_write, action report. How to connect one.

Your trail

Files you open will collect here, so you can find them again.

Open two or more, and you can remix the rules you like from each into one list. Kept in this browser only.

Now do this for your own.

Bring your CLAUDE.md, AGENTS.md or skills. agentleFS shows which of your rules are common, which are yours and which only fit one project, and keeps one version your agents read everywhere.