Skip to content

Commit 52dddf1

Browse files
authored
fix(iceberg): remove server option validator (#480)
1 parent 502f170 commit 52dddf1

File tree

1 file changed

+1
-10
lines changed

1 file changed

+1
-10
lines changed

wrappers/src/fdw/iceberg_fdw/iceberg_fdw.rs

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -367,16 +367,7 @@ impl ForeignDataWrapper<IcebergFdwError> for IcebergFdw {
367367
catalog: Option<pg_sys::Oid>,
368368
) -> IcebergFdwResult<()> {
369369
if let Some(oid) = catalog {
370-
if oid == FOREIGN_SERVER_RELATION_ID {
371-
// AWS credential pair must be specified together
372-
let a = check_options_contain(&options, "aws_access_key_id");
373-
let b = check_options_contain(&options, "aws_secret_access_key");
374-
match (a, b) {
375-
(a @ Err(_), Ok(_)) => a.map(|_| ())?,
376-
(Ok(_), b @ Err(_)) => b.map(|_| ())?,
377-
_ => (),
378-
}
379-
} else if oid == FOREIGN_TABLE_RELATION_ID {
370+
if oid == FOREIGN_TABLE_RELATION_ID {
380371
// check required option
381372
check_options_contain(&options, "table")?;
382373
}

0 commit comments

Comments
 (0)