From Todos to Trades: Building a NEPSE Moving‑Average Screener in 30 Minutes When I needed a quick proof‑of‑concept for a NEPSE technical‑analysis tool, the only data I had on hand was a public placeholder API. It sounded ab…
From API Calls to Alerts: Building a Production‑Ready Sequential Hypothesis Testing Pipeline Ever watched a dashboard flash “drift detected” every few minutes only to discover the model was fine? The culprit is usually a naïve per‑batch p‑v…
Two Years of Airflow at Scale: A Production‑Ready RSS Ingestion DAG from Stripe Blog Ever spent a whole afternoon watching an Airflow DAG sit idle because a simple RSS poll kept timing out, only to discover the backfill duplicated r…
Architecting for Change: Data Vault vs. Star Schema for Evolving API Data in a Lakehouse When a lakehouse ingests data from an upstream REST API that keeps adding fields, renaming columns, or mutating existing values, you quickly run in…
Beyond Atomic: Advanced Iceberg Lakehouse Patterns for Production Pipelines Ever stared at a growing lakehouse table and wondered how to add new rows without re‑scanning the whole thing, or how to slip a new column into a l…
Is Your RSS Feed Lying to You? Temporal Purity When Ingesting Discord Engineering's RSS I learned this the hard way while extending the NEPSE feature pipeline from my previous post. That pipeline guarded against macro-indicator leaka…