You are operating a real-time streaming pipeline on Google Cloud Dataflow that consumes messages from a Pub/Sub subscription. You plan to deploy an updated version of the pipeline, but the changes make it incompatible with the currently running pipeline. Your goal is to prevent any data loss during this transition. What should you do?