Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Metastore serial tests #5185

Merged
merged 1 commit into from
Jul 2, 2024
Merged

Metastore serial tests #5185

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
40 changes: 40 additions & 0 deletions quickwit/quickwit-metastore/src/tests/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -189,30 +189,35 @@ macro_rules! metastore_test_suite {
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_create_index_with_sources() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_create_index_with_sources::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_update_retention_policy() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_update_retention_policy::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_update_search_settings() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_update_search_settings::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_update_indexing_settings() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_update_indexing_settings::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_create_index_enforces_index_id_maximum_length() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_create_index_enforces_index_id_maximum_length::<
Expand All @@ -222,36 +227,42 @@ macro_rules! metastore_test_suite {
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_index_exists() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_index_exists::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_index_metadata() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_index_metadata::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_indexes_metadata() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_indexes_metadata::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_indexes() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_list_indexes::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_all_indexes() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_list_all_indexes::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_delete_index() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::index::test_metastore_delete_index::<$metastore_type>().await;
Expand All @@ -266,12 +277,14 @@ macro_rules! metastore_test_suite {
// - delete_splits

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_publish_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_publish_splits::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_publish_splits_concurrency() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_publish_splits_concurrency::<$metastore_type>(
Expand All @@ -280,6 +293,7 @@ macro_rules! metastore_test_suite {
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_publish_splits_empty_splits_array_is_allowed() {
$crate::tests::split::test_metastore_publish_splits_empty_splits_array_is_allowed::<
$metastore_type,
Expand All @@ -288,117 +302,137 @@ macro_rules! metastore_test_suite {
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_replace_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_replace_splits::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_mark_splits_for_deletion() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_mark_splits_for_deletion::<$metastore_type>()
.await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_delete_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_delete_splits::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_stream_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::list_splits::test_metastore_stream_splits::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_all_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::list_splits::test_metastore_list_all_splits::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::list_splits::test_metastore_list_splits::<$metastore_type>().await;
}


#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_splits_by_node() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::list_splits::test_metastore_list_splits_by_node_id::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_split_update_timestamp() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_split_update_timestamp::<$metastore_type>()
.await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_add_source() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::source::test_metastore_add_source::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_toggle_source() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::source::test_metastore_toggle_source::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_delete_source() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::source::test_metastore_delete_source::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_reset_checkpoint() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::source::test_metastore_reset_checkpoint::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_create_delete_task() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::delete_task::test_metastore_create_delete_task::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_last_delete_opstamp() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::delete_task::test_metastore_last_delete_opstamp::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_delete_index_with_tasks() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::delete_task::test_metastore_delete_index_with_tasks::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_delete_tasks() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::delete_task::test_metastore_list_delete_tasks::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_stale_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::list_splits::test_metastore_list_stale_splits::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_update_splits_delete_opstamp() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_update_splits_delete_opstamp::<$metastore_type>()
.await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_stage_splits() {
let _ = tracing_subscriber::fmt::try_init();
$crate::tests::split::test_metastore_stage_splits::<$metastore_type>().await;
Expand All @@ -407,31 +441,37 @@ macro_rules! metastore_test_suite {
/// Shard API tests

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_open_shards() {
$crate::tests::shard::test_metastore_open_shards::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_acquire_shards() {
$crate::tests::shard::test_metastore_acquire_shards::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_list_shards() {
$crate::tests::shard::test_metastore_list_shards::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_delete_shards() {
$crate::tests::shard::test_metastore_delete_shards::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_apply_checkpoint_delta_v2_single_shard() {
$crate::tests::shard::test_metastore_apply_checkpoint_delta_v2_single_shard::<$metastore_type>().await;
}

#[tokio::test]
#[serial_test::serial]
async fn test_metastore_apply_checkpoint_delta_v2_multi_shards() {
$crate::tests::shard::test_metastore_apply_checkpoint_delta_v2_multi_shards::<$metastore_type>().await;
}
Expand Down
Loading