fixes(cluster): try fix unit test failure
@@ -32,7 +32,7 @@ async fn test_successfully_add_node() -> Result<()> {
let node_info = create_test_node_info();
cluster_api.add_node(node_info.clone()).await?;
let value = kv_api
- .get_kv("__fd_clusters/admin//databend_query/test_node")
+ .get_kv("__fd_clusters/test%2dtenant%2did/test%2dcluster%2did/databend_query/test_node")
.await?;
match value {
@@ -121,7 +121,7 @@ async fn test_successfully_heartbeat_node() -> Result<()> {
cluster_api.add_node(node_info.clone()).await?;
let value = kv_api
- .get_kv("__fd_clusters/admin//databend_query/test_node")
+ .get_kv("__fd_clusters/test%2dtenant%2did/test%2dcluster%2did/databend_query/test_node")
.await?;
assert!(value.unwrap().meta.unwrap().expire_at.unwrap() - current_time >= 60);
@@ -130,7 +130,7 @@ async fn test_successfully_heartbeat_node() -> Result<()> {
cluster_api.heartbeat(&node_info, None).await?;
let value = kv_api
- .get_kv("__fd_clusters/admin//databend_query/test_node")
+ .get_kv("__fd_clusters/test%2dtenant%2did/test%2dcluster%2did/databend_query/test_node")
.await?;
assert!(value.unwrap().meta.unwrap().expire_at.unwrap() - current_time >= 60);
