You're overseeing a streaming Cloud Dataflow pipeline and your team has introduced a new version featuring an updated windowing algorithm and triggering strategy. What's the best method to upgrade the current pipeline to this new version without any data loss?
