Skip to content

Commit 82fa773

Browse files
committed
add create namespace if not exists
1 parent 8169575 commit 82fa773

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

tests/integration/test_register_table.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,7 @@ def test_register_table_existing_in_trino(
104104
table_name = "register_table_trino"
105105
identifier = f"{namespace}.{table_name}"
106106
location = f"s3a://warehouse/{namespace}/{table_name}"
107+
catalog.create_namespace_if_not_exists(namespace)
107108
tbl = _create_table(catalog, identifier, 2, location)
108109
assert catalog.table_exists(identifier=identifier)
109110
assert table_name in inspect(trino_conn).get_table_names(schema=namespace)

0 commit comments

Comments
 (0)