DATA OPS
Lineage-aware stale-table alerting (suppress downstream noise)
When multiple BigQuery tables go stale, walks the dependency graph to find the upstream root cause and alerts only on the root.
How it runs
The automated pipeline, trigger to output.
- TriggerScheduled freshness sweep
- ActionFetch last-refresh per monitored tableBigQuery
- ActionLoad lineage parent/child edgesBigQuery
- LogicResolve stale roots, suppress downstream victims
- OutputPost root cause + blast radius to SlackSlack
- OutputPage only for tier-1 root causesPagerDuty
What it does
When an upstream source stalls, every table that depends on it also goes stale, producing a storm of alerts. This workflow reads your declared lineage, identifies which stale tables are root causes versus downstream victims, and alerts only on the roots, listing the affected downstream tables as context.
When to use it
Use it when your warehouse has deep dependency chains and on-call gets buried in correlated freshness alerts during a single source outage. It turns 30 alerts into one actionable root-cause page.
How it works
- 1A schedule triggers the freshness sweep.
- 2A BigQuery query returns the last-refresh time for all monitored tables.
- 3A query against your lineage table loads parent/child edges between those tables.
- 4A logic step marks each stale table, then walks edges to keep only stale tables whose parents are fresh (the true roots) and groups their stale descendants.
- 5A Slack message posts each root cause with its blast-radius list.
- 6A PagerDuty incident opens only if a root sits in the tier-1 critical set.
Set it up
What you configure once, before turning it on.
- 1Connect BigQueryDatasets, queries, schemas.
- 2Connect SlackChannels, DMs, threads, mentions.
- 3Connect PagerDutyIncidents, on-call, escalations.
- 4Set each agent's modelWe leave models unset so you pick the tier — fast + cheap, or top-quality.
- 5Tune it to your dataEdit the prompts, filters, and field mappings so it matches how your team works.
- 6Test, then turn it onRun once against a sample, confirm the output, then enable the trigger.
More Data Ops workflows
Weekly BigQuery Cost Trend Sheet and Exec Digest
Compiles week-over-week BigQuery scheduled-query cost by owner and dataset into a Google Sheet with trend columns.
Daily BigQuery Scheduled-Query Cost Attribution to Owners
Each morning, totals the prior day's on-demand bytes-billed per scheduled query, maps each query to its owner from a label, and posts a per-owner cost leaderboard to Slack.
BigQuery Per-Team Budget Breach Alert to PagerDuty
Tracks month-to-date BigQuery scheduled-query spend per team and, when a team crosses its monthly budget, pages the team's on-call in PagerDuty and snapshots the spend breakdown…
dbt source freshness watcher with severity-routed alerts
Checks Snowflake loaded-at timestamps against each dbt source's freshness SLA, then routes warnings to Slack and hard breaches to a PagerDuty incident so stale data never…
dbt orphan model detector with Linear cleanup tickets
Scans your dbt manifest for models that no other model, exposure, or BI tool consumes.
Raw Sensor Telemetry Archive to BigQuery
Captures every incoming building sensor reading via webhook, normalizes the payload into a consistent schema.
Run it inside a business
This workflow drops into a full company template. Import the org, and this is one of the playbooks its agents run.

Run this workflow in your colony.
14-day trial. No DevOps. No Sales call. Provisioned in under a minute.
