Skip to content

Commit ac2e809

Browse files
committed
rebase
1 parent df809ab commit ac2e809

5 files changed

Lines changed: 7 additions & 6 deletions

File tree

pyiceberg/catalog/__init__.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,8 @@
3737
NamespaceAlreadyExistsError,
3838
NoSuchNamespaceError,
3939
NoSuchTableError,
40-
NoSuchViewError,
4140
NotInstalledError,
4241
TableAlreadyExistsError,
43-
ViewAlreadyExistsError,
4442
)
4543
from pyiceberg.io import FileIO, load_file_io
4644
from pyiceberg.manifest import ManifestFile

pyiceberg/catalog/bigquery_metastore.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -334,6 +334,9 @@ def load_view(self, identifier: str | Identifier) -> View:
334334
raise NotImplementedError
335335

336336
@override
337+
def rename_view(self, from_identifier: str | Identifier, to_identifier: str | Identifier) -> None:
338+
raise NotImplementedError
339+
337340
def load_namespace_properties(self, namespace: str | Identifier) -> Properties:
338341
dataset_name = self.identifier_to_database(namespace)
339342

pyiceberg/catalog/rest/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1475,7 +1475,7 @@ def drop_view(self, identifier: str | Identifier) -> None:
14751475
_handle_non_200_response(exc, {404: NoSuchViewError})
14761476

14771477
@retry(**_RETRY_ARGS)
1478-
def rename_view(self, from_identifier: Union[str, Identifier], to_identifier: Union[str, Identifier]) -> None:
1478+
def rename_view(self, from_identifier: str | Identifier, to_identifier: str | Identifier) -> None:
14791479
payload = {
14801480
"source": self._split_identifier_for_json(from_identifier),
14811481
"destination": self._split_identifier_for_json(to_identifier),

pyiceberg/catalog/sql.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -785,5 +785,5 @@ def close(self) -> None:
785785
if hasattr(self, "engine"):
786786
self.engine.dispose()
787787

788-
def rename_view(self, from_identifier: Union[str, Identifier], to_identifier: Union[str, Identifier]) -> None:
788+
def rename_view(self, from_identifier: str | Identifier, to_identifier: str | Identifier) -> None:
789789
raise NotImplementedError

tests/catalog/test_rest.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3189,8 +3189,8 @@ def test_rename_view_204(rest_mock: Mocker) -> None:
31893189
catalog = RestCatalog("rest", uri=TEST_URI, token=TEST_TOKEN)
31903190
catalog.rename_view(from_identifier, to_identifier)
31913191
assert (
3192-
rest_mock.last_request.text
3193-
== '''{"source": {"namespace": ["some_namespace"], "name": "old_view"}, "destination": {"namespace": ["some_namespace"], "name": "new_view"}}'''
3192+
rest_mock.last_request.text == """{"source": {"namespace": ["some_namespace"], "name": "old_view"}, """
3193+
""""destination": {"namespace": ["some_namespace"], "name": "new_view"}}"""
31943194
)
31953195

31963196

0 commit comments

Comments
 (0)