We need a principled way of managing state in real-time ML pipelines.