Fixed lint (#565)

tensorlakeai · May 3, 2024 · 2b5f1a7 · 2b5f1a7
1 parent 30d2601
commit 2b5f1a7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/state/grpc_server.rs b/src/state/grpc_server.rs
@@ -296,7 +296,7 @@ impl RaftApi for RaftGrpcServer {
                 .await
                 .map_err(|e| GrpcHelper::internal_err(e.to_string()))?;
             let forwarding_req = GrpcHelper::encode_raft_request(&StateMachineUpdateRequest {
-                payload: requests::RequestPayload::JoinCluster {
+                payload: RequestPayload::JoinCluster {
                     node_id,
                     address,
                     coordinator_addr,

diff --git a/src/state/mod.rs b/src/state/mod.rs
@@ -215,7 +215,7 @@ impl App {
             addr.to_string(),
             server_config.coordinator_addr.clone(),
         ));
-        let (leader_change_tx, leader_change_rx) = tokio::sync::watch::channel::<bool>(false);
+        let (leader_change_tx, leader_change_rx) = watch::channel::<bool>(false);
 
         let metrics = Metrics::new(state_machine.clone());