How would you design a data pipeline to handle late-arriving data in an incremental loading scenario for Publicis Groupe?