
Overcoming the real-time ML bottleneck by extending the Chronon platform with Push Mode and Near-real-time Model Transform
Airbnb has overhauled its personalization model by integrating real-time guest interaction data into its search ranking using Chronon. By transitioning from scheduled daily batch runs to event-driven streaming pipelines, the platform now updates user search embeddings in near-real-time. This article details how they successfully balanced system latency, offline-online consistency, and model performance.
When scaling real-time recommendation systems, engineers should leverage standardized ML feature platform features like Chronon to enable near-real-time inference rather than building ad-hoc, use-case-specific streaming pipelines.
Airbnb's previous search ranking model relied on daily batch jobs to update embeddings from guest journeys, leading to an data staleness lag of up to two days and failing to capture immediate search intent during active planning.
Airbnb integrated two new general-purpose capabilities—'Push Mode' and 'Near-real-time (NRT) Model Transform'—into its open-source ML feature platform, Chronon, enabling instantaneous model inference and embedding updates triggered by streaming guest activity.
The update latency for guest embeddings was reduced from up to two days to under a minute (typically 10 to 30 seconds), yielding a +1.67% NDCG improvement in offline evaluations and a 0.33% increase in uncancelled bookings during online A/B testing.
Trade-off
Shifting from batch to near-real-time streaming inference introduces higher operational complexity and streaming compute costs, demanding robust monitoring to ensure reliable event streaming sequence and pipeline health.
Airbnb's open-source machine learning feature platform designed to unify batch and streaming feature engineering and serving.
A Chronon feature where streaming jobs publish a lightweight notification as soon as a feature value is committed, acting as an event-driven trigger.
A platform capability in Chronon that allows deployed ML models to be executed directly within the streaming pipeline data flow.




