How would you handle backfilling historical data in a production pipeline without breaking downstream consumers?