Skip to content

Commit 869a6eb

Browse files
committed
remove extra get_pb
1 parent f569125 commit 869a6eb

File tree

2 files changed

+0
-10
lines changed

2 files changed

+0
-10
lines changed

src/meta/api/src/data_mask_api_impl.rs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -66,11 +66,6 @@ impl<KV: kvapi::KVApi<Error = MetaError>> DatamaskApi for KV {
6666
name_ident.tenant().clone(),
6767
name_ident.data_mask_name().to_string(),
6868
);
69-
if self.get_pb(&row_access_name_ident).await?.is_some() {
70-
return Ok(Err(
71-
name_ident.exist_error("name conflicts with an existing masking policy")
72-
));
73-
}
7469

7570
let masking_policy_id = fetch_id(self, IdGenerator::data_mask_id()).await?;
7671

src/meta/api/src/row_access_policy_api_impl.rs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -65,11 +65,6 @@ impl<KV: kvapi::KVApi<Error = MetaError>> RowAccessPolicyApi for KV {
6565
name_ident.tenant().clone(),
6666
name_ident.row_access_name().to_string(),
6767
);
68-
if self.get_pb(&mask_name_ident).await?.is_some() {
69-
return Ok(Err(
70-
name_ident.exist_error("name conflicts with an existing masking policy")
71-
));
72-
}
7368

7469
let row_access_id = fetch_id(self, IdGenerator::row_access_id()).await?;
7570
let policy_id = RowAccessPolicyId::new(row_access_id);

0 commit comments

Comments
 (0)