Skip to content

Commit 14d45c0

Browse files
committed
add schema to test
1 parent d519c40 commit 14d45c0

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

tests/integration/test_catalog.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -359,14 +359,14 @@ def test_update_namespace_properties(test_catalog: Catalog, database_name: str)
359359

360360
@pytest.mark.integration
361361
@pytest.mark.parametrize("test_catalog", CATALOGS)
362-
def test_register_table(test_catalog: Catalog, table_name: str, database_name: str) -> None:
362+
def test_register_table(test_catalog: Catalog, table_schema_nested: Schema, table_name: str, database_name: str) -> None:
363363
identifier = (database_name, table_name)
364364

365365
test_catalog.create_namespace_if_not_exists(database_name)
366366

367367
table = test_catalog.create_table(
368368
identifier=identifier,
369-
schema=Schema(),
369+
schema=table_schema_nested,
370370
)
371371

372372
assert test_catalog.table_exists(identifier)
@@ -378,14 +378,14 @@ def test_register_table(test_catalog: Catalog, table_name: str, database_name: s
378378

379379
@pytest.mark.integration
380380
@pytest.mark.parametrize("test_catalog", CATALOGS)
381-
def test_register_table_existing(test_catalog: Catalog, table_name: str, database_name: str) -> None:
381+
def test_register_table_existing(test_catalog: Catalog, table_schema_nested: Schema, table_name: str, database_name: str) -> None:
382382
identifier = (database_name, table_name)
383383

384384
test_catalog.create_namespace_if_not_exists(database_name)
385385

386386
table = test_catalog.create_table(
387387
identifier=identifier,
388-
schema=Schema(),
388+
schema=table_schema_nested,
389389
)
390390

391391
assert test_catalog.table_exists(identifier)

0 commit comments

Comments
 (0)