chore(toolchain): use toml format in feature-store rust-toolchain

integration_tests/feature-store/simulator/Cargo.toml

@@ -20,6 +20,3 @@ prost = "0.10"
 serde = { version = "1", features = ["derive"] }
 futures = "0.3.0"
 csv = "1.2.2"
-
-[lints]
-workspace = true

integration_tests/feature-store/simulator/rust-toolchain

@@ -1 +1,2 @@
-nightly-2022-06-20
+[toolchain]
+channel = "nightly-2023-09-09"

integration_tests/feature-store/simulator/src/entities.rs

@@ -60,7 +60,7 @@ impl User {
 
         Ok(ActionHistory {
             userid: self.userid.clone(),
-            changenum: changenum,
+            changenum,
             event_type: event_type.to_string(),
             timestamp,
         })
@@ -93,5 +93,5 @@ pub fn parse_user_metadata() -> Result<Vec<User>, ()> {
 
     let users = read_users_json(Path::new(&*generator_path).join("users.json")).unwrap();
 
-    return Ok(users);
+    Ok(users)
 }

integration_tests/feature-store/simulator/src/entities_taxi.rs

@@ -101,7 +101,7 @@ impl TaxiFeature {
                 mta_tax: self.mta_tax,
                 tip_amount: self.tip_amount,
                 tolls_amount: self.tolls_amount,
-                ehail_fee: self.ehail_fee.unwrap_or_else(|| 0.0),
+                ehail_fee: self.ehail_fee.unwrap_or(0.0),
                 improvement_surcharge: self.improvement_surcharge,
                 total_amount: self.total_amount,
                 payment_type: self.payment_type,

integration_tests/feature-store/simulator/src/simulation.rs

@@ -4,7 +4,6 @@ use std::thread::sleep;
 use std::time::Duration;
 
 use futures::future::join_all;
-use rand;
 use rand::Rng;
 use tokio::sync::Mutex;
 use tonic::transport::Channel;
@@ -15,7 +14,7 @@ use crate::{entities, entities_taxi};
 
 fn get_delay_mills(delay_val: f64) -> u64 {
     let turbulence =
-        rand::thread_rng().gen_range((delay_val * 0.6) as f64, (delay_val * 1.1) as f64) as f64;
+        rand::thread_rng().gen_range(delay_val * 0.6, delay_val * 1.1);
     (turbulence * 10000.0) as u64
 }
 
@@ -33,7 +32,7 @@ pub async fn main_loop(simulator_type: String) {
     }
 }
 
-async fn mock_taxi(client: Arc<Mutex<ServerClient<Channel>>>) -> () {
+async fn mock_taxi(client: Arc<Mutex<ServerClient<Channel>>>) {
     let (offline_features, online_features) = entities_taxi::parse_taxi_metadata();
     println!("Write training data len is {:?}", offline_features.len());
     let mut threads = vec![];
@@ -87,7 +86,7 @@ async fn mock_taxi(client: Arc<Mutex<ServerClient<Channel>>>) -> () {
 }
 
 #[allow(dead_code)]
-async fn mock_user_mfa(client: Arc<Mutex<ServerClient<Channel>>>) -> () {
+async fn mock_user_mfa(client: Arc<Mutex<ServerClient<Channel>>>) {
     let users = entities::parse_user_metadata().unwrap();
     let mut threads = vec![];
     for user in users {