Skip to content

perf(tests/rust): share tables at module level and remove in-test deletes #197

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

Open
pdf-amzn wants to merge 1 commit into
base: main
Choose a base branch
from
Open

perf(tests/rust): share tables at module level and remove in-test deletes #197

Show file tree
Hide file tree
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
4 changes: 0 additions & 4 deletions tests/rust/src/authorization.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -99,8 +99,6 @@ async fn unknown_access_key_rejected() {
err_code(&err).is_some(),
"Expected auth error, got: {err:?}"
);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -165,6 +163,4 @@ async fn valid_credentials_put_and_get() {
.unwrap();
let item = resp.item().expect("Item should exist");
assert_eq!(item.get("data").unwrap().as_s().unwrap(), "auth_test");

c.delete_table().table_name(&table).send().await.ok();
}
10 changes: 0 additions & 10 deletions tests/rust/src/backup_restore.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,6 @@ async fn create_backup_happy_case() {
assert!(!details.backup_arn().is_empty());
assert_eq!(details.backup_status().as_str(), "AVAILABLE");

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -108,7 +107,6 @@ async fn describe_backup() {
let desc = resp.backup_description().unwrap();
assert_eq!(desc.backup_details().unwrap().backup_arn(), arn.as_str());

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand All @@ -135,7 +133,6 @@ async fn list_backups() {
let resp = c.list_backups().table_name(&table).send().await.unwrap();
assert!(resp.backup_summaries().len() >= 2);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand All @@ -147,7 +144,6 @@ async fn list_backups_empty() {
let resp = c.list_backups().table_name(&table).send().await.unwrap();
assert!(resp.backup_summaries().is_empty());

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand All @@ -166,7 +162,6 @@ async fn delete_backup() {
"DELETED"
);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -209,8 +204,6 @@ async fn restore_table_from_backup() {
let scan = c.scan().table_name(&restored).send().await.unwrap();
assert_eq!(scan.count(), 5);

c.delete_table().table_name(&restored).send().await.ok();
c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand All @@ -227,7 +220,6 @@ async fn describe_continuous_backups() {
.unwrap();
assert!(resp.continuous_backups_description().is_some());

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -264,7 +256,6 @@ async fn enable_point_in_time_recovery() {
"ENABLED"
);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand All @@ -284,5 +275,4 @@ async fn restore_table_to_point_in_time() {
.await;
assert!(err.is_err(), "RestoreTableToPointInTime should return an error (not yet supported)");

c.delete_table().table_name(&table).send().await.ok();
}
7 changes: 0 additions & 7 deletions tests/rust/src/capacity_throttling.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,6 @@ async fn get_item_consumed_capacity_total() {
assert_eq!(cap.table_name().unwrap(), table.as_str());
assert!(cap.capacity_units().unwrap() > 0.0);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand All @@ -116,7 +115,6 @@ async fn put_item_consumed_capacity_total() {
assert_eq!(cap.table_name().unwrap(), table.as_str());
assert!(cap.capacity_units().unwrap() > 0.0);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -145,7 +143,6 @@ async fn scan_consumed_capacity_total() {
let cap = resp.consumed_capacity().unwrap();
assert!(cap.capacity_units().unwrap() > 0.0);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand All @@ -171,7 +168,6 @@ async fn no_consumed_capacity_by_default() {

assert!(resp.consumed_capacity().is_none());

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -213,7 +209,6 @@ async fn per_partition_write_throttling() {
"Expected some writes throttled. Succeeded: {succeeded}, Throttled: {throttled}"
);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -255,7 +250,6 @@ async fn provisioned_table_write_throttling() {
"Expected some writes throttled (1 WCU). Succeeded: {succeeded}, Throttled: {throttled}"
);

c.delete_table().table_name(&table).send().await.ok();
}

#[tokio::test]
Expand Down Expand Up @@ -305,5 +299,4 @@ async fn provisioned_table_read_throttling() {
"Expected some reads throttled (1 RCU). Succeeded: {succeeded}, Throttled: {throttled}"
);

c.delete_table().table_name(&table).send().await.ok();
}
14 changes: 0 additions & 14 deletions tests/rust/src/gsi_more.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -93,13 +93,6 @@ async fn create_table_with_gsi_keys_only_projection() {
!result.contains_key("extra"),
"KEYS_ONLY projection should not include non-key attributes"
);

c.delete_table()
.table_name(&table_name)
.send()
.await
.unwrap();
wait_for_deleted(c, &table_name).await;
}

#[tokio::test]
Expand Down Expand Up @@ -187,13 +180,6 @@ async fn create_table_with_gsi_include_projection() {
!result.contains_key("excluded_attr"),
"INCLUDE projection should not include non-projected attributes"
);

c.delete_table()
.table_name(&table_name)
.send()
.await
.unwrap();
wait_for_deleted(c, &table_name).await;
}

#[tokio::test]
Expand Down
Loading
Loading