On this page
Can an AI agent do data engineering?
Part of it, with a person approving each change. AI agents for data engineering can draft pipeline code, profile and clean raw tables, add data quality checks, write documentation and diagnose failed runs. A data engineer still reviews every change before it reaches production, owns metric definitions and decides what the agent may access.
Two companies describe using one, both quoted by Google. Vodafone's head of engineering says Google's Data Engineering Agent replicated "all existing data and transformations scripts" during its migration to Dataform and cut the time typically required for manual ETL migration by 90%; that is Vodafone's figure, and the method is not published. PRISA Media's lead data engineer says the agent "already delivers value in automating maintenance and small optimizations."
The independent evidence is more cautious. In ELT-Bench, a 2025 research benchmark of 100 pipelines with 835 source tables and 203 data models, the best agent tested loaded data successfully for 57% of pipelines but built only 3.9% of data models correctly, at an average cost of $4.30 per pipeline in model usage. The models tested have since been replaced, so read the gap between loading and modeling as the finding, not the exact numbers.
What the agent does and what stays with you
Agent
1of 10
- Write pipeline and column documentation
Agent with review
7of 10
- Draft pipeline code from a written description of sources, targets and rules
- Profile and clean raw data (types, duplicates, formats)
- Map a source schema to a target schema
- Add data quality checks to tables
- Diagnose failed pipeline runs
- Apply fixes to production pipelines and data
- Translate pipelines during a platform migration
Human
2of 10
- Define business logic and metrics (what counts as revenue or an active customer)
- Grant access, set credentials and decide what the agent may write to
10 tasks: 1 agent, 7 agent with review, 2 human
| Task | Who does it | Why |
|---|---|---|
| Draft pipeline code from a written description of sources, targets and rules | Agent with review | Google says its agent generates pipeline code in Dataform from natural language and validates compilation errors; a person reviews and runs the pipeline. |
| Profile and clean raw data (types, duplicates, formats) | Agent with review | Google documents the agent sampling up to 1,000,000 records per table and proposing a wrangling plan for you to review before any action occurs. |
| Map a source schema to a target schema | Agent with review | Google's agent produces a mapping plan with join paths and a field-level gap analysis that you review before it builds the pipeline. |
| Add data quality checks to tables | Agent with review | Google says the agent infers checks from schema and samples; you still decide which business rules the checks must enforce. |
| Write pipeline and column documentation | Agent | Google says the agent generates pipeline documentation and column descriptions; spot-check them, since wrong documentation is cheap to correct. |
| Diagnose failed pipeline runs | Agent with review | Google says the agent analyzes execution logs and suggests a fix, and Orchestra's template has an agent list each error, cause, evidence and suggested fix. |
| Apply fixes to production pipelines and data | Agent with review | Orchestra's template and DataKitchen's pattern both apply a fix only after a person approves it. |
| Translate pipelines during a platform migration | Agent with review | Vodafone, as quoted by Google, used the agent to replicate existing scripts in Dataform; test each migrated output against the old system. |
| Define business logic and metrics (what counts as revenue or an active customer) | Human | In ELT-Bench the best agent built 3.9% of data models correctly, and DataKitchen says intent, not SQL, is what an agent cannot decide. |
| Grant access, set credentials and decide what the agent may write to | Human | Orchestra's docs tell you to scope the agent's permissions to what it genuinely needs; that decision stays with the data owner. |
The split follows how easy the work is to check. Compiling code, loading rows and writing column descriptions have a clear right answer. Business logic does not. A join can be valid SQL and still change revenue. DataKitchen's CEO puts the line at intent: whether 222 invalid state codes should become NULL or map to real states "is a business call."
Google's documentation requires you to review and run or schedule pipelines, and Orchestra's template pauses for human approval before applying a proposed fix. Google says its agent can generate a plan listing its objective, assumptions and the files it will modify, and that it "cannot execute pipelines. You must review and run or schedule pipelines." Orchestra's pipeline fixer template has one agent investigate a failed run, posts the error, cause, suggested fix and evidence to Slack for approval, and only then runs a second agent to apply the fix. Not every product works this way: Snowflake's product page for CoCo describes automations that run recurring workflows even when your computer is closed, with an audit trail of each run. The product page does not specify whether these automations have a human-approval gate; confirm the controls available before relying on them.

A worked example: one failed nightly run
This is an illustration, not a customer story. Assume, for this example, that a nightly pipeline builds an orders table and a not-null test on the customer ID column fails for every row in last night's batch.
The agent reads the run logs, queries the source schema with its read-only role, and finds that the source column was renamed. It opens a pull request that maps the new column name to the old one, runs the model in the development schema, and shows a reconciliation query: yesterday's order count and revenue match the source system's totals.
Your engineer reads the pull request in the morning, checks with the source team that the rename is permanent, and merges. If the source team had said the rename would be rolled back, the right answer was to wait, and the agent could not have known that. The agent saved the log reading; the engineer made the call.
What you need to provide
Access is the first decision. Give the agent a read-only warehouse role on source and production schemas, and write access only to a development schema or branch. Changes reach production through pull requests and your normal deployment, never through the agent's own credentials. Orchestra's documentation warns that its second agent "applies changes without further review, so scope the agent's permissions to what it genuinely needs," and advises starting with a single pipeline rather than every pipeline in the account.
The agent will touch whatever data those schemas hold: customer records, orders, often personal information. Google says its agent can read sample rows and data profiles as context, does not use them for training, and can use glossary terms to tag columns containing personal information for special handling. Check your own provider's terms on retention and processing location.
Give it your rules in writing: naming conventions, style guide, metric definitions. Google supports an agent instruction file for exactly this, and notes that agent behavior changes over time with model upgrades, so you should retest your rules. Finally, give it known numbers to reconcile against, such as last month's revenue in the finance report. Data jobs fail silently; a reconciliation check is how you hear about it.
Job brief template
Use this as the brief for a vendor, an operator or your own team. Replace the bracketed values with your own.
Copy-ready brief
- Goal
- Every requested pipeline change and every failed run in [scope] gets a reviewed fix or draft within [1] business day, and no change reaches production without a named engineer's approval.
- Deliverable
- Pull requests in [repository] with the code change, a plain-language summary, the tests added and the result of a reconciliation query, plus a weekly log of failed runs with cause, evidence and the fix proposed.
- Inputs
- A written list of pipelines in scope, with their sources, targets and owners
- A read-only warehouse role on source and production schemas, and write access only to a development schema or branch
- Access to the code repository through pull requests, not direct pushes to the main branch
- Run logs from the orchestrator for the pipelines in scope
- Your naming conventions, style guide and written metric definitions (for example as an agent instruction file)
- Known reconciliation numbers: for example last month's order count and revenue as reported in finance
- Acceptance criteria
- Every pull request compiles and passes the existing test suite in the development environment.
- Each changed model's row counts and key totals match a known reference figure (for example last month's revenue in the finance report) within [0.1%], with the query shown.
- No pull request changes a metric definition or business rule without that change named in the summary.
- On a sample of 10 diagnosed failures, the engineer agrees with the stated cause in at least [8].
- The agent's role has no write access to production schemas; the access review shows none.
- Systems
- cloud data warehouse (for example BigQuery or Snowflake)
- transformation tool (for example Dataform or dbt)
- orchestrator (for example Airflow)
- code repository with pull requests
- team chat or ticketing system for approvals
- Constraints
- The agent may read data that includes customer or personal information; limit its role to the schemas in scope and mask or exclude sensitive columns where you can.
- Check your provider's data retention and processing-location terms before giving the agent sample rows.
- No direct writes to production tables; changes go through pull requests and your normal deployment.
- Credentials come from your platform's access controls, never pasted into prompts.
- Volume
- Example: 20–80 pipelines in scope, 5–20 change requests and 5–30 failed runs a month
- Cadence
- Example: failed runs diagnosed on the morning after they fail; change requests reviewed twice a week
- Human checkpoints
- Metric definitions and business rules: the data owner approves any change before merge.
- Pull requests: a named engineer reads the diff and the reconciliation result before merge.
- Fixes to failed runs: the engineer confirms the stated cause, for example with the source system's owner, before approving.
- Access: the data owner reviews the agent's roles at the start of the trial and after every scope change.
The reconciliation criterion does most of the work. Tests catch broken code; only a comparison with a number someone already trusts catches a pipeline that runs and is wrong.
Risks and human checkpoints
A change runs cleanly and passes null and uniqueness tests but changes a business number, for example through a wrong join that double-counts orders.
How you notice it
Require a reconciliation query against a known reference figure in every pull request, and compare key dashboard totals before and after each merge.
The agent resolves an ambiguous rule in the wrong direction, for example nulling values that should have been mapped.
How you notice it
Require ambiguous rules to be listed in the pull request summary; DataKitchen's pattern files proposed fixes with affected row counts for approval.
The agent references a column that does not exist or misreads a renamed one.
How you notice it
Compile and run every change in a development environment before review; failed compilation never reaches the reviewer.
A fix applied with broad credentials changes pipelines outside the intended scope.
How you notice it
Start with one pipeline, as Orchestra's docs advise, and check the access review and audit log after each change.
The diagnosis names the wrong cause because the real cause sits outside the logs, such as an unannounced source change.
How you notice it
Score a weekly sample of diagnoses against what the engineer found; count disagreements.
Human checkpoints
- Metric definitions and business rules: the data owner approves any change before merge.
- Pull requests: a named engineer reads the diff and the reconciliation result before merge.
- Fixes to failed runs: the engineer confirms the stated cause, for example with the source system's owner, before approving.
- Access: the data owner reviews the agent's roles at the start of the trial and after every scope change.
For context on the human side of the trade, BLS has no separate occupation for data engineers. The closest it reports, database architects, had a median annual wage of $139,500 in May 2025. This page shows no agent price: Snowflake bills CoCo by token consumption, and no sourced per-pipeline range was found, so there is no cost comparison here.
How to run a trial
Run the agent beside your engineers before you rely on it. Our suggestion: four weeks, long enough to see routine failures and at least one change request.
- Pick a slice: three to five pipelines with good tests and a known reference number.
- Set up the access in the brief: read-only on production, write on a development schema, pull requests only.
- Send it every failed run and change request in the slice. Your engineers keep working as usual.
- Score each pull request: did it compile, did the reconciliation match, did the reviewer accept it unchanged.
- Plant a test: introduce a deliberate double-count in a development copy and check whether the agent's reconciliation catches it.
- Time the reviews. Hours spent checking the agent are the cost you trade against engineering time.
Pick a slice
Three to five pipelines with good tests and a known reference number
Set up the access in the brief
Read-only on production, write on a development schema, pull requests only
Send it every failed run and change request
Your engineers keep working as usual
Score each pull request
Did it compile, did the reconciliation match, did the reviewer accept it unchanged
Plant a test
A deliberate double-count in a development copy; does the agent's reconciliation catch it
Time the reviews
Hours spent checking the agent are the cost you trade against engineering time
If the agent meets the brief's criteria for the whole trial, widen the scope one pipeline at a time. Keep metric definitions, access and production merges with your team.
For structuring the test, see how to run a paid trial with an AI agent and how to supervise an AI agent. Related pages: reporting and BI, spreadsheet analysis, the data analyst role, data entry and the data overview.
Questions buyers ask
Will an agent replace my data engineer? No source here says so. The customer quotes cited describe the agent taking over migration scripts, maintenance and small optimizations. The Google documentation and Orchestra workflow described here keep a human review step; the sources cited do not establish whether every product does. BLS projects employment of database architects, the closest occupation it reports, to grow 9% from 2025 to 2035.
Where should I start? Our recommendation: start with diagnosing failed runs and writing documentation. Both are easy to check, and a wrong answer costs a few minutes of review. Move to pipeline changes once the agent's pull requests pass your reconciliation checks.
Can I let it fix pipelines on its own overnight? Google's agent cannot run pipelines itself, and Orchestra's template waits for approval before applying a fix. Our recommendation: keep that gate. If you remove it, you lose the step that catches a change that runs cleanly and is wrong.
Does it need to see my data? Usually some of it. Google's agent samples rows and profiles to plan transformations. Limit the role to the schemas in scope and keep sensitive columns out where you can.
Sources
- Data Engineering Agent overview
Google CloudPrimaryAccessed Nov 14, 2026
- Exploring the Data Engineering Agent in BigQuery
Google CloudVendorAccessed Nov 14, 2026
- ELT-Bench: An End-to-End Benchmark for Evaluating AI Agents on ELT Pipelines
arXiv (Jin, Zhu and Kang)PrimaryAccessed Nov 14, 2026
- Snowflake CoCo: Snowflake-Native AI Coding Agent for Data
SnowflakeVendorAccessed Nov 14, 2026
- Agentic Pipeline Fixer with Human Approvals
OrchestraPrimaryAccessed Nov 14, 2026
- Agents to Fix Data Quality Automatically With Control: A Design Pattern
DataKitchenVendorAccessed Nov 14, 2026
- Database Administrators and Architects, Occupational Outlook Handbook
U.S. Bureau of Labor StatisticsPrimaryAccessed Nov 14, 2026
What we could not verify
- Production evidence comes from vendors: Vodafone's and PRISA Media's use of Google's Data Engineering Agent is quoted on Google's own blog. Vodafone's 90% time reduction is Vodafone's figure as quoted by Google; the method is not published.
- ELT-Bench is an arXiv paper from April 2025. Whether it has since been peer reviewed was not checked, and it measured models that have since been replaced. No newer independent benchmark of agents building pipelines was found.
- Agent pricing is not shown. Snowflake bills CoCo by token consumption and Google's Data Engineering Agent pricing was not researched to a sourced range, so the page has no cost comparison.
- BLS has no separate occupation for data engineers. The closest BLS occupation used for context here is database architects.
Related
- AI agents for data analysis and BI: what to hand over
- AI agents for business intelligence and reporting
- AI agent for spreadsheet analysis: what it can do
- Can AI replace data analysts? A task-by-task answer
- AI agent for data entry: what it does, what you check
- How to hire an AI agent: scope, brief, trial, supervision
- How to test an AI agent before buying: run a paid trial
- How to manage AI agents: review, escalation, handover
