Skip to content

Commit 131dd15

Browse files
authored
REST: Pass purgeRequest to catalog (#2086)
1 parent f4da19e commit 131dd15

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

pyiceberg/catalog/rest/__init__.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ class Endpoints:
9595
register_table = "namespaces/{namespace}/register"
9696
load_table: str = "namespaces/{namespace}/tables/{table}"
9797
update_table: str = "namespaces/{namespace}/tables/{table}"
98-
drop_table: str = "namespaces/{namespace}/tables/{table}?purgeRequested={purge}"
98+
drop_table: str = "namespaces/{namespace}/tables/{table}"
9999
table_exists: str = "namespaces/{namespace}/tables/{table}"
100100
get_token: str = "oauth/tokens"
101101
rename_table: str = "tables/rename"
@@ -617,7 +617,8 @@ def load_table(self, identifier: Union[str, Identifier]) -> Table:
617617
@retry(**_RETRY_ARGS)
618618
def drop_table(self, identifier: Union[str, Identifier], purge_requested: bool = False) -> None:
619619
response = self._session.delete(
620-
self.url(Endpoints.drop_table, prefixed=True, purge=purge_requested, **self._split_identifier_for_path(identifier)),
620+
self.url(Endpoints.drop_table, prefixed=True, **self._split_identifier_for_path(identifier)),
621+
params={"purgeRequested": purge_requested},
621622
)
622623
try:
623624
response.raise_for_status()

0 commit comments

Comments
 (0)