Airflow publishes ride events to Kafka. Spark writes a Parquet snapshot of the rides that pass the checks.
Health: checking…