Your production demand forecasting pipeline preprocesses raw data using Dataflow before model training and prediction. This involves applying Z-score normalization to data in BigQuery and then writing it back. With new training data added weekly, your goal is to enhance efficiency by reducing both computation time and manual effort. What steps should you take to achieve this?