WORKFLOW TEMPLATES
Data Ops workflows
Sync, enrich, and pipeline data between systems.
378 workflows
Realtime BigQuery Table-Create PII Alert
On a BigQuery audit-log webhook for any newly created or replaced table, classifies its columns for PII and, if sensitive fields are unprotected, files a Linear ticket and pings…
Agent-assisted BigQuery export that clarifies intent before masked delivery
An agent reads a plain-English export request from a webhook, builds and confirms the BigQuery query, masks PII, and delivers the file to Dropbox after Slack sign-off.
AI Triage of Quarantined Reverse-ETL Rows
An agent reviews quarantined rows, classifies each failure into fixable versus permanent, repairs the safe ones, re-syncs them, and opens a Linear ticket summarizing the systemic…
Agent-Driven dbt Failure Triage and Root-Cause Brief
On a dbt failure it spins up an agent that reads the error, inspects upstream source freshness and recent model changes in GitHub.
Agent-Driven CSV Schema Drift Triage and Partner Outreach
When a partner CSV fails validation, an agent diagnoses whether the failures are schema drift or dirty data, files a Linear issue with the analysis.
Agent-Driven dbt Freshness Incident Investigator
On a freshness alert, an agent investigates across BigQuery, Honeycomb, and dbt logs, writes a plain-English root-cause hypothesis, and posts a summarized incident brief to Slack.
Multi-Warehouse PII Drift Register in Airtable
Sweeps both BigQuery and Snowflake on a schedule, consolidates every newly detected sensitive column into a single Airtable data-governance register.
Pre-share PII gate: block presigned-URL requests for exposed files
A webhook fires before a presigned download URL is issued; it scans the requested S3 object for PII, blocks the share and archives evidence to Dropbox if found.
Snowflake Freshness Breach RCA Agent: Investigate and Draft Incident Report
On a freshness breach, an agent investigates likely causes across the warehouse, orchestration logs, and recent code changes.
Agent-Driven Freshness Breach Triage with Root-Cause Note in Linear
When a source breaches its freshness SLA, an agent investigates the likely cause across recent loads and logs, drafts a plain-English root-cause summary.
Daily Cross-Warehouse PII Inventory Snapshot to R2
Builds a unified daily inventory of every classified PII column across both Snowflake and BigQuery, writes the versioned snapshot to R2.
Reverse-ETL Backfill Investigation Agent
On a manually triggered backfill, an agent reconciles warehouse rows against Salesforce, investigates why specific rows dropped by reading sync logs.
Datadog Freshness Metric Breach: Auto-Triage and Halt the Pipeline
Receives a Datadog monitor alert when a table-freshness metric breaches, classifies it as a load delay versus a hard failure.
Reverse-ETL Row-Count Reconciliation Gate
After each reverse-ETL run, reconciles the row count Snowflake intended to sync against the count HubSpot actually accepted and emits a Datadog metric plus a Slack alert…
Snapshot a BigQuery anomaly to a Google Doc investigation record
When a BigQuery metric anomaly fires, it snapshots the offending query results to BigQuery-backed CSV in cloud storage.
BigQuery DDL Webhook Drift Triage with Agent Severity Call
Receives BigQuery audit-log DDL events via webhook in near real time, has an agent assess the change against the table's documented contract and downstream consumers.
Build the Error-to-Report Correlation Store From Front and Intercom
On a schedule, this scans recent Front and Intercom conversations, fingerprints any errors they mention, matches them to Sentry issues.
Reverse-ETL Multi-Destination Coverage Check
Verifies that a single warehouse audience landed completely across multiple destinations (Salesforce, HubSpot.
Agent that triages BigQuery schema changes and files fix tickets in Linear
An agent investigates each BigQuery schema change end to end — reading lineage and query logs.
Weekly PII drift governance digest to Notion register
Compiles the week's column-classification changes across BigQuery into a written summary and updates a Notion data-governance register so stewards have a single living record…
Daily BigQuery schema change digest to Slack
Each morning, summarizes every BigQuery table schema change from the last 24 hours into a single readable Slack digest.
Daily BigQuery schema change digest to Slack
Each morning, summarizes every BigQuery table schema change from the last 24 hours into a single readable Slack digest.
BigQuery Regression LLM Root-Cause Explainer
On a detected cost spike it sends the old and new query SQL plus job stats to an LLM, which explains in plain English why the query got more expensive and suggests a concrete fix.
Monthly BigQuery Cost Optimization Briefing for Leadership
An agent reviews the month's BigQuery spend by team label, identifies the costliest recurring queries and likely optimizations.
Postgres Replica Freshness Circuit Breaker for Reverse-ETL
Before each reverse-ETL sync, verifies the analytics Postgres replica is fresh; if replication lag exceeds the window, it blocks the sync, opens a Linear issue.
BigQuery Cost Anomaly Root-Cause Triage Agent
When a cost anomaly webhook fires, an agent investigates the offending BigQuery query — inspecting plan, partition usage, and recent edits.
dbt Run Failure Owner Pager
Receives dbt run-result webhooks, identifies which models failed and who owns them, and pages the on-call data engineer through PagerDuty only when a model tagged critical breaks.
Agentic BigQuery Grant Lifecycle Reviewer with Linear Tickets
An agent reviews grants nearing expiry, decides per-grant whether to auto-extend low-risk access, revoke unused access, or open a Linear ticket for human review.
Agent-driven root-cause triage for late BigQuery partitions
When a partition lands late, an agent investigates the likely cause by querying load-job history and upstream source freshness.
Reverse-ETL Post-Sync Validator: Row-Count and Recency Check on Webhook
Fires when your reverse-ETL tool reports a sync finished, then validates that warehouse and destination row counts match and the data is recent — alerting Slack on any mismatch.
Weekly Snowflake Schema-Change Digest to Notion and Slack
Runs weekly, collects every column add, drop, and type change across watched Snowflake schemas.
Open a Linear ticket when a BigQuery slot spike is traced to one author
On a webhook from BigQuery slot-usage alerting, identifies the single author responsible for the spike and files a Linear ticket assigned to them with the offending job, slot…
Reverse-ETL Freshness Triage Agent: Diagnose Stale Sync and File Linear Ticket
When a sync goes stale, an agent investigates the likely cause across warehouse query logs and ETL metadata, then files a Linear ticket with its diagnosis and pings Slack.
Schema-Drift Triage Agent that Maps Impact and Files a Linear Issue
When BigQuery schema drift is detected, an agent traces which downstream models, dashboards, and pipelines depend on the changed column, writes a plain-English impact assessment.
Drift impact analyst with downstream lineage
When a Snowflake column drifts, an agent traces which downstream models, dashboards, and dbt nodes depend on it.
Escalate repeat BigQuery slot offenders to PagerDuty after nudges are ignored
Tracks daily slot-contention nudges per author and, when the same author tops the contention ranking three days running, escalates to the on-call data platform owner…
Consent-and-PII Gate Before Salesforce Lead Writeback
Webhook-triggered guard that screens enriched leads for missing consent flags and invalid PII before upserting to Salesforce.
BigQuery Orphaned & Overdue Grant Audit with PagerDuty Escalation
Daily, cross-checks live BigQuery IAM bindings against the grant ledger to find untracked or long-overdue access, posts an audit summary to Slack.
Operational Postgres Source Drift Watcher
Monitors application Postgres tables that feed the warehouse, detects when a source schema changes ahead of its Snowflake ingest contract.
Nightly PII sweep of an R2 bucket with a digest report
On a nightly schedule, scans all objects in a Cloudflare R2 bucket for exposed PII, tags offenders, and posts a ranked digest of the worst exposures to Slack plus a full…
Dropped-column impact analysis with Linear issue and owner notification
When a Snowflake column is dropped or renamed, traces which downstream tables and dbt models reference it, files a Linear issue scoped to the impact.
Dropped-column impact analysis with Linear issue and owner notification
When a Snowflake column is dropped or renamed, traces which downstream tables and dbt models reference it, files a Linear issue scoped to the impact.
Governed BigQuery extract to Dropbox with PII masking and Slack approval
Fulfills an ad-hoc data export request by running a BigQuery query, masking PII columns, then waiting for a Slack approval before delivering the file to Dropbox.
BigQuery export with size-based routing and dual approval for large pulls
Runs a BigQuery export and routes it by row count: small masked pulls auto-deliver to Dropbox, large pulls require a second data-owner approval in Slack first.
BigQuery Multi-Table Freshness Sweep with Morning SLA Digest
Each morning, sweeps a registry of BigQuery tables against their individual SLA windows and posts one ranked Slack digest of every stale table.
BigQuery Team Budget Breach Detector with PagerDuty Escalation
Hourly, accumulates each team's month-to-date BigQuery spend against budgets stored in Airtable.
Snowflake Untagged-PII PagerDuty Escalation
Watches Snowflake for new columns missing a sensitivity tag, classifies them, and escalates high-confidence PII to PagerDuty as an incident while logging everything else…
Escalate critical BigQuery SLA breaches to PagerDuty
Fires when a freshness-breach event arrives by webhook, and for tier-1 tables that are past a hard deadline it opens or updates a PagerDuty incident with the table, lateness…
Weekly cross-warehouse PII exposure digest
Samples new columns across both Snowflake and BigQuery each week and compiles a single ranked Notion report of unmasked-PII exposure by team and table, with a Slack summary.
Post-sync verification webhook with auto-rollback flag
Triggered by the reverse-ETL platform's sync-complete webhook, immediately re-reads the just-pushed records from Salesforce and compares them to BigQuery.
Weekly Postgres PII Drift Audit Report
Once a week, an agent crawls your Postgres analytics database for unclassified columns, samples and classifies them for PII.
Weekly Warehouse Cost Digest to Notion with AI Owner Notes
Every Monday, pulls the prior week's BigQuery and Snowflake credit spend by owner, uses an LLM to write a plain-English summary of who drove the change and why.
dbt Anomaly Recovery Auto-Close for PagerDuty and Linear
Re-checks tables that previously breached freshness or volume thresholds, and when a table has recovered it resolves the open PagerDuty incident, closes the Linear issue.
Three-way reconciliation of Postgres source, Intercom destination, and an audit ledger
Reconciles row counts across a Postgres audience query, the Intercom segment it feeds, and an Airtable audit log, then writes the daily reconciliation result back to Airtable.
Cross-Warehouse Reconciliation Check
Reconciles a shared metric (like daily revenue) between BigQuery and Snowflake each morning and opens a GitHub issue plus a Slack alert when the two warehouses disagree beyond…
Reconcile BigQuery audience row counts against HubSpot after each sync
After a reverse-ETL job pushes a BigQuery audience to HubSpot, this counts source rows versus synced contacts and alerts Slack when the delta exceeds a tolerance.
Pre-campaign audience gate: block sends until BigQuery and HubSpot agree
Before a campaign launches, verifies the BigQuery audience and the HubSpot list match on both row count and freshness, and either approves the launch in Slack or holds it.
Daily BigQuery schema-change digest with owner-routed Notion entries
Once a day, summarize every BigQuery schema change in the last 24 hours, map each to its downstream owners, and log an owner-tagged entry to a Notion review tracker.
On-demand cross-warehouse PII audit agent with Linear remediation
On a chat request, an agent audits a named table across BigQuery and Snowflake, reasons about which columns drifted into PII.
Real-Time Postgres DDL PII Guard via Webhook
Triggered the moment a DDL change webhook fires, inspects the altered Postgres table for newly added sensitive columns and immediately opens a governance ticket plus a PagerDuty…
Start with a template, not a blank canvas.
14-day trial. No DevOps. No Sales call. Provisioned in under a minute.