let now = data_time; -> let now = Decimal::from(Utc::now().timestamp_millis());

strategy/src/predictor.rs

@@ -461,7 +461,7 @@ impl Predictor {
         let is_delta_changed = self.update_delta().await;
 
         // let cci_arc = self.cci_arc.clone();
-        let now = data_time;
+        let now = Decimal::from(Utc::now().timestamp_millis());
         let mid_price = self.mid_price;
         let ask_price = if self.params.ref_exchange.len() > 0 {
             self.fair_price_std_vec[0]