Airflow cutover
Legacy orchestrator retired; billing CDC pipelines moved to Airflow with prod-safe table references.
Bronze/silver/gold billing pipelines on S3, change-data-capture services migrated to Airflow, and a reliable refunds path into Redshift.
Problem
A legacy orchestrator was being retired while billing and refunds data needed a medallion architecture. Change-data-capture tables behaved differently across environments, and new payment and refund tables needed merges, data-quality checks, and warehouse loads.
Approach
Migrate billing CDC pipelines to Airflow with custom SQL and primary-key tests. Deploy bronze-to-silver dedup for change-data-capture operations, then ship the refunds orchestration path to production.
Architecture
Medallion billing path
CDC microservices through bronze, silver dedup, and gold into Redshift.
Drag nodes to explore the flow
Solution highlights
Legacy orchestrator retired; billing CDC pipelines moved to Airflow with prod-safe table references.
Bronze, silver, and gold buckets with Athena merges and Glue jobs.
Refunds orchestration deployed and the Redshift load path validated.
Custom SQL and primary-key tests for the new Airflow patterns.
CDC behavior reconciled so dev and prod pipelines matched.