diff --git a/src/meta-srv/src/procedure/region_migration/downgrade_leader_region.rs b/src/meta-srv/src/procedure/region_migration/downgrade_leader_region.rs index ae9f65a625c8..8b6d8e815770 100644 --- a/src/meta-srv/src/procedure/region_migration/downgrade_leader_region.rs +++ b/src/meta-srv/src/procedure/region_migration/downgrade_leader_region.rs @@ -278,6 +278,12 @@ mod tests { assert_matches!(err, Error::PusherNotFound { .. }); assert!(!err.is_retryable()); + let err = state + .downgrade_region_with_retry(&mut ctx) + .await + .unwrap_err(); + assert_matches!(err, Error::PusherNotFound { .. }); + assert!(!err.is_retryable()); } #[tokio::test] @@ -316,6 +322,13 @@ mod tests { assert_matches!(err, Error::ExceededDeadline { .. }); assert!(!err.is_retryable()); + + let err = state + .downgrade_region_with_retry(&mut ctx) + .await + .unwrap_err(); + assert_matches!(err, Error::ExceededDeadline { .. }); + assert!(!err.is_retryable()); } #[tokio::test]