fixup! Add support for registering views

Author: ebyhr

pyiceberg/catalog/rest/__init__.py

@@ -1322,11 +1322,11 @@ def view_exists(self, identifier: str | Identifier) -> bool:
     @retry(**_RETRY_ARGS)
     def register_view(self, identifier: str | Identifier, metadata_location: str) -> View:
         self._check_endpoint(Capability.V1_REGISTER_VIEW)
-        namespace_and_view = self._split_identifier_for_path(identifier)
-        request = RegisterViewRequest(
-            name=self._identifier_to_validated_tuple(identifier)[-1],
-            metadata_location=metadata_location,
-        )
+        if self.table_exists(identifier):
+            raise TableAlreadyExistsError()
+
+        namespace_and_view = self._split_identifier_for_path(identifier, IdentifierKind.VIEW)
+        request = RegisterViewRequest(name=namespace_and_view["view"], metadata_location=metadata_location)
         serialized_json = request.model_dump_json().encode(UTF8)
         response = self._session.post(
             self.url(Endpoints.register_view, namespace=namespace_and_view["namespace"]),

tests/catalog/test_rest.py

@@ -2138,11 +2138,10 @@ def test_register_view_200(rest_mock: Mocker, example_view_metadata_rest_json: d
         identifier=("default", "registered_view"),
         metadata=ViewMetadata(**example_view_metadata_rest_json["metadata"]),
     )
-    assert actual.metadata.model_dump() == expected.metadata.model_dump()
-    assert actual.name() == expected.name()
+    assert actual == expected
 
 
-def test_register_view_409(rest_mock: Mocker) -> None:
+def test_register_view_409_view(rest_mock: Mocker) -> None:
     rest_mock.post(
         f"{TEST_URI}v1/namespaces/default/register-view",
         json={
@@ -2164,6 +2163,21 @@ def test_register_view_409(rest_mock: Mocker) -> None:
     assert "View already exists" in str(e.value)
 
 
+def test_register_view_409_table(rest_mock: Mocker) -> None:
+    rest_mock.post(
+        f"{TEST_URI}v1/namespaces/default/views/registered_view",
+        status_code=204,
+        request_headers=TEST_HEADERS,
+    )
+
+    catalog = RestCatalog("rest", uri=TEST_URI, token=TEST_TOKEN)
+    with pytest.raises(TableAlreadyExistsError) as e:
+        catalog.register_view(
+            identifier=("default", "registered_view"), metadata_location="s3://warehouse/database/view/metadata.json"
+        )
+    assert "Table already exists" in str(e.value)
+
+
 def test_drop_view_invalid_namespace(rest_mock: Mocker) -> None:
     view = "view"
     with pytest.raises(NoSuchIdentifierError) as e: