Ultimate access to all questions.
You are managing a streaming Cloud Dataflow pipeline that processes real-time data. Your engineering team has developed an updated version of this pipeline that includes changes to the windowing algorithm and triggering strategy. Your objective is to deploy this new version to replace the currently running one. It's critical to perform the update in such a way that ensures no data is lost during the transition. What steps should you take to achieve this?