Dispatch to Arrival — what one system hands the other

Dispatch to Arrival — what one system hands the other An architecture diagram generated by Archify. Kafka · trip events, keyed by trip_id · Dispatch — the pipeline that measures the promise Kafka trip events, keyed by trip_id Spark · streams to bronze · Dispatch — the pipeline that measures the promise Spark streams to bronze dbt marts · silver to gold · Dispatch — the pipeline that measures the promise dbt marts silver to gold fct_trip · one row per trip · Dispatch — the pipeline that measures the promise · the contract fct_trip one row per trip the contract Feature store · features.py · Arrival — the service that replaces it · as_of carried Feature store features.py as_of carried Training · chronological split · Arrival — the service that replaces it Training chronological split Model artifact · content-hashed · Arrival — the service that replaces it Model artifact content-hashed Serving · PredictionService · Arrival — the service that replaces it Serving PredictionService Dispatcher · needs an ETA now · Architecture component Dispatcher needs an ETA now Monitoring · drift, realised accuracy · Arrival — the service that replaces it Monitoring drift, realised accuracy at-least-once deduplicated measured trips assigned_at bounds every window as of each assigned_at fitted weights loaded by version as of now — same declarations ETA predictions, at once labels, 35 min later Dispatch — the pipeline that measures the promise Arrival — the service that replaces it Legend Backend Database Message bus External