Skip to content

Commit 4672e15

Browse files
committed
lint
1 parent c028042 commit 4672e15

File tree

2 files changed

+9
-6
lines changed

2 files changed

+9
-6
lines changed

pyiceberg/catalog/rest.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -918,9 +918,7 @@ def view_exists(self, identifier: Union[str, Identifier]) -> bool:
918918
bool: True if the view exists, False otherwise.
919919
"""
920920
response = self._session.head(
921-
self.url(
922-
Endpoints.view_exists, prefixed=True, **self._split_identifier_for_path(identifier, IdentifierKind.VIEW)
923-
),
921+
self.url(Endpoints.view_exists, prefixed=True, **self._split_identifier_for_path(identifier, IdentifierKind.VIEW)),
924922
)
925923
if response.status_code == 404:
926924
return False

tests/integration/test_writes/test_writes.py

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1424,18 +1424,23 @@ def test_table_v1_with_null_nested_namespace(session_catalog: Catalog, arrow_tab
14241424
# We expect no error here
14251425
session_catalog.drop_table(identifier)
14261426

1427+
14271428
@pytest.mark.integration
1428-
def test_view_exists(spark: SparkSession, session_catalog: Catalog,) -> None:
1429+
def test_view_exists(
1430+
spark: SparkSession,
1431+
session_catalog: Catalog,
1432+
) -> None:
14291433
identifier = "default.some_view"
14301434
spark.sql(
14311435
f"""
14321436
CREATE VIEW {identifier}
1433-
AS
1437+
AS
14341438
(SELECT 1 as some_col)
14351439
"""
14361440
).collect()
14371441
assert session_catalog.view_exists(identifier)
1438-
session_catalog.drop_view(identifier) # clean up
1442+
session_catalog.drop_view(identifier) # clean up
1443+
14391444

14401445
@pytest.mark.integration
14411446
def test_overwrite_all_data_with_filter(session_catalog: Catalog) -> None:

0 commit comments

Comments
 (0)