merge from upstream/main
@@ -87,6 +87,20 @@ async fn test_meta_grpc_client_database_rename() -> anyhow::Result<()> {
SchemaApiTestSuite {}.database_rename(&client).await
}
+#[tokio::test(flavor = "multi_thread", worker_threads = 3)]
+async fn test_meta_grpc_client_database_drop_undrop_list_history() -> anyhow::Result<()> {
+ let (_log_guards, ut_span) = init_meta_ut!();
+ let _ent = ut_span.enter();
+
+ let (_tc, addr) = start_metasrv().await?;
+
+ let client = MetaGrpcClient::try_create(vec![addr], "root", "xxx", None, None).await?;
+
+ SchemaApiTestSuite {}
+ .database_drop_undrop_list_history(client.as_ref())
+ .await
+}
+
#[tokio::test(flavor = "multi_thread", worker_threads = 3)]
async fn test_meta_grpc_client_table_create_get_drop() -> anyhow::Result<()> {
let (_log_guards, ut_span) = init_meta_ut!();
@@ -127,6 +141,20 @@ async fn test_meta_grpc_client_table_upsert_option() -> anyhow::Result<()> {
.await
}
+#[tokio::test(flavor = "multi_thread", worker_threads = 3)]
+async fn test_meta_grpc_client_table_drop_undrop_list_history() -> anyhow::Result<()> {
+ let (_log_guards, ut_span) = init_meta_ut!();
+ let _ent = ut_span.enter();
+
+ let (_tc, addr) = start_metasrv().await?;
+
+ let client = MetaGrpcClient::try_create(vec![addr], "root", "xxx", None, None).await?;
+
+ SchemaApiTestSuite {}
+ .table_drop_undrop_list_history(client.as_ref())
+ .await
+}
+
#[tokio::test(flavor = "multi_thread", worker_threads = 3)]
async fn test_meta_grpc_client_table_list() -> anyhow::Result<()> {
let (_log_guards, ut_span) = init_meta_ut!();
