Arrival — ETA prediction with a point-in-time feature store

Arrival — ETA prediction with a point-in-time feature store An architecture diagram generated by Archify. Dispatch · fct_trip (gold) · Architecture component · upstream Dispatch fct_trip (gold) upstream source.py · warehouse or seeded · Architecture component source.py warehouse or seeded features.py · one declaration, two paths · Architecture component · point-in-time features.py one declaration, two paths point-in-time train.py · ridge, chronological split · Offline — training train.py ridge, chronological split registry.py · artifacts/<hash> · Offline — training registry.py artifacts/<hash> serve.py · PredictionService · Online — serving · p50 10ms · p99 2s serve.py PredictionService p50 10ms · p99 2s Dispatcher · asks for an ETA · Online — serving Dispatcher asks for an ETA experiment.py · hashed arms, MDE · Architecture component experiment.py hashed arms, MDE monitor.py · drift, lagged labels · Architecture component · 35 min blind monitor.py drift, lagged labels 35 min blind docs / dashboard · generated at build time · Architecture component docs / dashboard generated at build time completed trips Trip rows point-in-time versioned artifact load model online(now) Prediction observe() predictions now labels, 35 min late arm by hash health Offline — training Online — serving Legend Frontend Backend Database External