ML Engineer
Feature stores with provenance you can defend. Trace every feature to source tables and catch schema drift before AUC drops.
Executive summary
Register feature tables and training pipelines in Metroflow. Alert on upstream schema changes. Document feature DAGs for compliance in one click.
Features look stable until an upstream column changes overnight. Without lineage, you debug in notebooks for days. Metroflow traces features from raw ingest to production models.
What broken lineage costs you
Typical patterns for ML Engineer teams. Ranges, not guarantees.
Overnight schema change
Silent AUC degradation for days
With Metroflow: Alert when upstream columns change.
Compliance review
Stale diagrams and notebook exports
With Metroflow: Live feature DAG export from graph.
Undocumented feature sources
Cannot explain model behavior
With Metroflow: Trace churn_features → dim_customers → raw_hubspot.
Training-serving skew
Different SQL in batch vs online
With Metroflow: One lineage path for both pipelines.
Metadata only. Metroflow crawls schemas, job names, manifests, and dashboard definitions. Your production data rows never leave your network.
Your stack, one graph
Metroflow sits above the data path, not inside it. One searchable map for your entire role.
Trace churn_features → dim_customers → raw_hubspot. When orders_v2 changes, see every training job that consumes it.
Where are you today?
Most teams land at L1 or L2. Target L4 in 90 days.
Quick self-check
- Answer "what breaks if X fails?" in under 15 minutes?
- Cross-functional teams share one definition of core KPIs?
- Incidents include downstream dashboard impact without Slack archaeology?
- Changes include cross-layer impact checks before merge?
- Named owners for certified metrics and critical pipelines?
0–2: Start Week 1 connect · 3–4: Certify metrics · 5: Add change gates
Choose your path
Every org is different. Pick the track closest to your context.
Warehouse-native features
Features built in dbt/SQL, batch training
Priority: Register first: top 5 production model feature sets
Feature store (Feast/Tecton)
Online + offline feature serving
Priority: Register first: link store entities to warehouse sources
Real-time inference
Stream features + batch backfill
Priority: Register first: stream-to-feature lineage
Who owns what
Assign decision rights up front. Metric fights are governance problems.
| Role | Owns | On Metroflow |
|---|---|---|
| ML engineer | Features, training, deployment | Own feature DAG documentation. Schema drift monitors. |
| Analytics engineer | Upstream dbt models | Notify ML on breaking schema changes. |
| Data governance | Model risk, compliance | Export lineage for reviews. |
| Data platform | Pipelines, compute | Link training jobs to orchestration metadata. |
30 · 60 · 90 day rollout
A program with gates, not just a connector checklist.
Map features
- Register top production models
- Trace features to warehouse sources
- First schema drift alert
Guardrails
- Alerts on upstream column changes
- Compliance export template
- Training job registry
Operationalize
- Pre-merge ML impact for AE PRs
- Monthly model risk review
- Automated feature DAG for auditors
Incident runbook
When churn_model_v3 is in trouble. Follow this timeline.
Production metric below threshold. Check recent schema changes.
Column renamed in staging. Training-serving skew confirmed.
Coordinate with AE on schema fix. Retrain with updated features.
Update feature DAG. Post-mortem with lineage proof.
Slack template
Metric certification pack
Copy into your governance doc. One definition. One owner. Full lineage.
Feature freshness (SLA)
Track first- Formula
- Max lag between source table update and feature store refresh.
- Threshold
- Alert if > 24h for tier-1 features.
- Owner
- ML Eng + Platform
Feature lineage coverage
Track second- Formula
- % of production features with documented path to raw source.
- Target
- 100% by day 60.
- Owner
- ML Eng + Governance
Daily workflows
Four situations you will hit every week.
New model launch
- Document features
Register in graph.
- Compliance export
DAG for model risk.
- Drift monitors
Upstream column alerts.
AUC drop investigation
- Check schema changes
Last 7 days upstream.
- Trace features
Training vs serving paths.
- Retrain plan
Coordinate with AE.
Before AE schema PR
- ML impact query
Affected features and models.
- Sign-off
Approve or request migration.
- Update docs
Feature DAG refresh.
Quarterly model review
- Lineage audit
100% coverage check.
- Stale features
Deprecate unused.
- Export for auditors
One-click report.
Copy-paste queries
Company Brain or lineage search. Context included.
Glossary
Plain English. "Why it matters" tells you when to care.
Outcomes checklist
Measure if the program is working.
| Success metric | 90-day target |
|---|---|
| Time to debug feature / schema issue | < 2 hours |
| Production features with lineage | 100% |
| Schema drift caught before AUC impact | ≥ 90% of cases |
| Compliance export time | Minutes vs days |
Ready to put this playbook to work?
Week 1: connect your stack and run your first blast-radius query. Week 4: certify your first KPI. Week 8: operationalize the runbook.