diff --git a/src/common/meta/src/kv_backend/etcd.rs b/src/common/meta/src/kv_backend/etcd.rs index 0b3b45b9bc..7bd172427e 100644 --- a/src/common/meta/src/kv_backend/etcd.rs +++ b/src/common/meta/src/kv_backend/etcd.rs @@ -100,7 +100,7 @@ impl EtcdStore { .with_label_values(&["etcd", "txn"]) .start_timer(); let txn = Txn::new().and_then(part); - self.client.kv_client().txn(txn).await + self.kv_client().txn(txn).await }) .collect::>();