
Lakevector Case Studies
Learn more about our work.
Client: Regional Financial Services Firm (anonymized)
Industry: Financial Services / Asset Management
Data Scale: Multi-petabyte Databricks data lake, 300+ scheduled pipelines
Engagement Type: Orchestration Platform Migration + Pipeline Modernization
Why They Left Databricks Jobs
Vendor Lock-In Was a Strategic Risk
Databricks Jobs only orchestrates Databricks. Every pipeline, every trigger, every dependency had to live inside the Databricks ecosystem. As the firm expanded its stack — adding Snowflake for serving, dbt for transformation, and custom Python services for pricing data ingestion — Databricks Jobs could not orchestrate across those boundaries. The team was forced to maintain a patchwork of cron jobs and external scripts alongside Databricks Jobs, creating a fragmented and unauditable control plane. Leadership viewed the single-vendor dependency as an unacceptable strategic risk.
DAG Complexity Had Outgrown the Scheduler
Databricks Jobs supports linear task dependencies within a single job. The firm’s pipelines were not linear. Risk models depended on multiple upstream data feeds completing successfully. Regulatory reports had conditional branches based on market hours and data availability. Restatement workflows required dynamic task generation based on the number of affected periods. None of this could be expressed cleanly in Databricks Jobs — teams were hacking around limitations with polling jobs and sentinel files, creating fragile, hard-to-maintain pipelines that regularly failed in non-obvious ways.
Compliance and Auditability Requirements
Financial services firms operate under strict regulatory obligations around data lineage, pipeline traceability, and audit logging. Databricks Jobs provided limited metadata — run logs existed, but there was no structured way to query pipeline history, trace a data artifact back to its originating job run, or produce the kind of execution audit trail that regulators expect. Airflow’s metadata database, combined with structured logging and task-level provenance, gave the compliance team the auditability infrastructure they needed.
SLA Monitoring Was Non-Existent
The firm’s most critical pipelines — end-of-day position feeds, overnight risk calculations, and morning reporting packages — had strict delivery SLAs. Databricks Jobs had no native SLA tracking. When a pipeline ran long, nobody knew until a downstream consumer complained. Airflow’s built-in SLA miss detection and alerting gave the operations team proactive visibility, allowing them to intervene before an SLA breach became a business incident.
On-Demand Cluster Spin-Up Was Costing Them at Scale
Because Databricks Jobs spun up a cluster for every task — even lightweight coordination tasks that did nothing more than trigger a downstream job or check a file’s existence — the firm was paying DBU costs for work that consumed almost no compute. Airflow separates orchestration from execution: the scheduler is a lightweight service, and compute is only provisioned when actual work runs. For a portfolio of 300+ pipelines, this distinction had material cost implications.
Talent and Ecosystem
Airflow is the de facto standard for data orchestration. It has a massive open-source ecosystem with 1,000+ providers covering every major data platform, cloud service, and API. Recruiting engineers familiar with Databricks Jobs is a narrow hiring target. Recruiting Airflow engineers is straightforward. The firm’s engineering leadership wanted their orchestration layer to be a skill their entire data team could own — not a proprietary scheduler that required Databricks-specific expertise to operate and debug.
The Engagement
Lakevector planned and executed the migration in three phases, with zero tolerance for pipeline downtime given the firm’s regulatory obligations.
Phase 1: Pipeline Inventory and DAG Design
We began with a full audit of the existing Databricks Jobs catalog — 300+ jobs ranging from simple notebook runs to multi-task dependency chains. Each pipeline was classified by:
Complexity — Linear vs. branching vs. dynamic workflows
Criticality — Regulatory, SLA-bound, or best-effort promises
External dependencies — Databricks-only vs. cross-platform environments
This inventory drove the migration sequencing and informed the Airflow DAG architecture. Pipelines were redesigned from the ground up rather than translated 1:1 — taking the opportunity to eliminate redundant jobs, consolidate fragmented workflows, and implement proper error handling and retry logic that had never existed in the original scheduler.
Phase 2: Airflow Infrastructure and Provider Integration
Our team deployed a managed Airflow environment (Apache Airflow on MWAA) with production-grade configuration: isolated task execution, secret management via AWS Secrets Manager, structured logging to S3, and the metadata database tuned for query performance at scale.
Provider integrations were configured for:
Databricks — Notebook and job triggering via the Databricks provider
Snowflake — SQL execution and data transfer operators
dbt — Transformation job orchestration via the dbt provider
Custom operators — Proprietary pricing feed ingestion and regulatory submission workflows built as reusable Airflow plugins
Phase 3: Migration Execution and Cutover
Pipelines were migrated in priority order — lowest criticality first, regulatory pipelines last. Each migrated DAG ran in parallel with its Databricks Jobs equivalent during a validation window, with automated output comparison to verify correctness before the legacy job was retired.
SLA definitions were codified for every time-sensitive pipeline. Alerting was wired to PagerDuty for on-call escalation and to Slack for team-level visibility. The compliance team received access to a structured audit log interface backed by the Airflow metadata database.
Cutover was completed with no missed SLAs and no regulatory incidents.
The Results
Pipelines migrated: 300+
Orchestration vendor dependency: Eliminated
SLA miss incidents post-migration: Zero in first 90 days
Audit trail coverage: 100% of pipeline executions
Orchestration compute cost reduction: ~40% (separation of orchestration from execution)
Cross-platform pipeline coverage: Databricks, Snowflake, dbt, custom APIs all unified
Downtime during migration: Zero
The Lasting Impact
The migration did more than swap one scheduler for another. It gave the firm a single, auditable control plane for all data movement — regardless of where that data lives or what system processes it. Engineering teams now write DAGs in standard Python, onboard faster, and operate pipelines they can actually reason about when things go wrong.
The compliance team has the audit trail they always needed. Operations has SLA visibility before failures become incidents. And leadership has eliminated a strategic dependency that had quietly constrained every infrastructure decision for years.
Why Lakevector
Lakevector specializes in data platform migrations for organizations where data is mission-critical and downtime is not an option. We bring the engineering depth to redesign pipelines correctly — not just translate them — and the operational rigor to execute migrations without disrupting the business.
If your orchestration layer is limiting your platform, we should talk.
Talk to an Expert Today