A retail company runs a critical streaming Dataflow pipeline that reads from Pub/Sub, applies transformations, and writes aggregated sales into BigQuery. The data engineering team needs to deploy a new pipeline version that adds a field to the output schema, but they must not lose any in-flight messages or duplicate already-processed data during the transition. Which approach should they use to stop the currently running job?