chore(ci): make ci success (#18672)

ci: make ci success

https://github.com/databendlabs/databend/actions/runs/17403752206/job/49402771308

Author: TCeason

src/query/service/src/interpreters/interpreter_table_create.rs

@@ -342,6 +342,7 @@ impl CreateTableInterpreter {
             invalid_cache = true;
         }
 
+        // TODO: can refactor into create_table in one txn
         // if old_table_id is some means create or replace is success, we should delete the old table id's ownership key
         if let Some(old_table_id) = reply.old_table_id {
             role_api

src/query/service/tests/it/storages/fuse/operations/create_or_replace_ownership_object.rs

@@ -18,7 +18,7 @@ use databend_common_base::base::tokio;
 use databend_common_config::MetaConfig;
 use databend_common_exception::ErrorCode;
 use databend_common_exception::Result;
-use databend_common_meta_api::SchemaApi;
+use databend_common_meta_api::kv_pb_api::KVPbApi;
 use databend_common_meta_app::principal::OwnershipObject;
 use databend_common_meta_app::principal::TenantOwnershipObjectIdent;
 use databend_common_meta_store::MetaStore;
@@ -87,7 +87,7 @@ async fn test_fuse_db_table_create_replace_clean_ownership_key() -> Result<()> {
             table_id: old_tbl_id,
         };
         let table_ownership_key = TenantOwnershipObjectIdent::new(tenant.clone(), table_ownership);
-        let v = meta.get(&table_ownership_key).await?;
+        let v = meta.get_pb(&table_ownership_key).await?;
         assert!(v.is_some());
 
         fixture
@@ -96,7 +96,7 @@ async fn test_fuse_db_table_create_replace_clean_ownership_key() -> Result<()> {
                 catalog_name, db_name, tbl_name
             ))
             .await?;
-        let v = meta.get(&table_ownership_key).await?;
+        let v = meta.get_pb(&table_ownership_key).await?;
         assert!(v.is_none());
 
         let tbl_name = "ownership_table_test";
@@ -115,7 +115,7 @@ async fn test_fuse_db_table_create_replace_clean_ownership_key() -> Result<()> {
         };
         let table_ownership_key =
             TenantOwnershipObjectIdent::new(tenant.clone(), table_ownership.clone());
-        let v = meta.get(&table_ownership_key).await?;
+        let v = meta.get_pb(&table_ownership_key).await?;
         assert!(v.is_some());
 
         fixture
@@ -128,7 +128,7 @@ async fn test_fuse_db_table_create_replace_clean_ownership_key() -> Result<()> {
         let second_create_id = tbl.get_table_info().ident.table_id;
         assert_ne!(second_create_id, first_create_id);
         let db_ownership_key = TenantOwnershipObjectIdent::new(tenant.clone(), table_ownership);
-        let v = meta.get(&db_ownership_key).await?;
+        let v = meta.get_pb(&db_ownership_key).await?;
         assert!(v.is_none());
 
         let table_ownership = OwnershipObject::Table {
@@ -137,7 +137,7 @@ async fn test_fuse_db_table_create_replace_clean_ownership_key() -> Result<()> {
             table_id: second_create_id,
         };
         let db_ownership_key = TenantOwnershipObjectIdent::new(tenant.clone(), table_ownership);
-        let v = meta.get(&db_ownership_key).await?;
+        let v = meta.get_pb(&db_ownership_key).await?;
         assert!(v.is_some());
     }
 
@@ -159,7 +159,7 @@ async fn test_fuse_db_table_create_replace_clean_ownership_key() -> Result<()> {
         };
         let db_ownership_key =
             TenantOwnershipObjectIdent::new(tenant.clone(), db_ownership.clone());
-        let v = meta.get(&db_ownership_key).await?;
+        let v = meta.get_pb(&db_ownership_key).await?;
         assert!(v.is_some());
 
         fixture
@@ -173,15 +173,15 @@ async fn test_fuse_db_table_create_replace_clean_ownership_key() -> Result<()> {
         assert_ne!(second_create_db_id, first_create_db_id);
 
         let db_ownership_key = TenantOwnershipObjectIdent::new(tenant.clone(), db_ownership);
-        let v = meta.get(&db_ownership_key).await?;
+        let v = meta.get_pb(&db_ownership_key).await?;
         assert!(v.is_none());
 
         let db_ownership = OwnershipObject::Database {
             catalog_name: catalog_name.clone(),
             db_id: *second_create_db_id,
         };
         let db_ownership_key = TenantOwnershipObjectIdent::new(tenant.clone(), db_ownership);
-        let v = meta.get(&db_ownership_key).await?;
+        let v = meta.get_pb(&db_ownership_key).await?;
         assert!(v.is_some());
     }