Merge branch 'main' into add-mini-ontime

Author: mergify[bot]

docs/doc/02-cloud/index.md

@@ -21,10 +21,11 @@ To log in to your account, go to https://app.databend.com.
 
 ### Warehouses
 
-Virtual warehouses can be automatically suspended in case of no activities for a specific period.
+Serverless warehouses can be automatically suspended in case of no activities for a specific period.
 
 <img src="/img/cloud/databend_cloud_warehouse.png"/>
 
+
 ### Databases
 
 This page shows a list of your databases:
@@ -48,6 +49,8 @@ Worksheets is a powerful SQL editor where you can run SQL queries. For example,
 ### Connect to a Serverless Warehouse on Databend Cloud
 
 Databend Cloud provides a connection string for your applications to connect to it:
+<img src="/img/cloud/databend_cloud_warehouse_detail.png"/>
+<img src="/img/cloud/databend_cloud_warehouse_connect.png"/>
 
 ```shell
 https://<tenant>--<warehouse>.ch.aws-us-east-2.default.databend.com/

docs/public/img/cloud/databend_cloud_warehouse.png

@@ -34,7 +34,7 @@ use crate::tests::create_catalog;
 #[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_catalogs_get_database() -> Result<()> {
     let tenant = "test";
-    let catalog = create_catalog()?;
+    let catalog = create_catalog().await?;
 
     // get system database
     let database = catalog.get_database(tenant, "system").await?;
@@ -61,7 +61,7 @@ async fn test_catalogs_get_database() -> Result<()> {
 #[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_catalogs_database() -> Result<()> {
     let tenant = "admin";
-    let catalog = create_catalog()?;
+    let catalog = create_catalog().await?;
 
     let db_list = catalog.list_databases(tenant).await?;
     let db_count = db_list.len();
@@ -153,7 +153,7 @@ async fn test_catalogs_database() -> Result<()> {
 #[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_catalogs_table() -> Result<()> {
     let tenant = "test";
-    let catalog = create_catalog()?;
+    let catalog = create_catalog().await?;
 
     // Check system/default.
     {

docs/public/img/cloud/databend_cloud_warehouse_connect.png

@@ -95,7 +95,7 @@ async fn test_immutable_catalogs_database() -> Result<()> {
 #[tokio::test(flavor = "multi_thread", worker_threads = 1)]
 async fn test_immutable_catalogs_table() -> Result<()> {
     let tenant = "test";
-    let catalog = create_catalog()?;
+    let catalog = create_catalog().await?;
 
     let db_list_1 = catalog.list_tables(tenant, "system").await?;
     assert!(!db_list_1.is_empty());

docs/public/img/cloud/databend_cloud_warehouse_detail.png

@@ -34,17 +34,18 @@ async fn test_memorytable() -> Result<()> {
         DataField::new("a", u32::to_data_type()),
         DataField::new("b", u64::to_data_type()),
     ]);
-    let table = MemoryTable::try_create(crate::tests::create_storage_context()?, TableInfo {
-        desc: "'default'.'a'".into(),
-        name: "a".into(),
-        ident: Default::default(),
-        meta: TableMeta {
-            schema: schema.clone(),
-            engine: "Memory".to_string(),
-            options: TableOptions::default(),
-            ..Default::default()
-        },
-    })?;
+    let table =
+        MemoryTable::try_create(crate::tests::create_storage_context().await?, TableInfo {
+            desc: "'default'.'a'".into(),
+            name: "a".into(),
+            ident: Default::default(),
+            meta: TableMeta {
+                schema: schema.clone(),
+                engine: "Memory".to_string(),
+                options: TableOptions::default(),
+                ..Default::default()
+            },
+        })?;
 
     // append data.
     {

query/tests/it/catalogs/database_catalog.rs

@@ -31,7 +31,7 @@ async fn test_null_table() -> Result<()> {
         DataField::new("a", u64::to_data_type()),
         DataField::new("b", u64::to_data_type()),
     ]);
-    let table = NullTable::try_create(crate::tests::create_storage_context()?, TableInfo {
+    let table = NullTable::try_create(crate::tests::create_storage_context().await?, TableInfo {
         desc: "'default'.'a'".into(),
         name: "a".into(),
         ident: Default::default(),

query/tests/it/catalogs/immutable_catalogs.rs

@@ -15,9 +15,7 @@
 use common_exception::Result;
 use databend_query::catalogs::DatabaseCatalog;
 
-pub fn create_catalog() -> Result<DatabaseCatalog> {
-    futures::executor::block_on(async move {
-        let conf = crate::tests::ConfigBuilder::create().config();
-        DatabaseCatalog::try_create_with_config(conf).await
-    })
+pub async fn create_catalog() -> Result<DatabaseCatalog> {
+    let conf = crate::tests::ConfigBuilder::create().config();
+    DatabaseCatalog::try_create_with_config(conf).await
 }

query/tests/it/storages/memory.rs

@@ -92,8 +92,8 @@ pub async fn create_query_context_with_config(
     Ok(context)
 }
 
-pub fn create_storage_context() -> Result<StorageContext> {
-    let meta_embedded = futures::executor::block_on(MetaEmbedded::new_temp()).unwrap();
+pub async fn create_storage_context() -> Result<StorageContext> {
+    let meta_embedded = MetaEmbedded::new_temp().await.unwrap();
 
     Ok(StorageContext {
         meta: Arc::new(meta_embedded),