|
42 | 42 | from pyiceberg.table.metadata import INITIAL_SPEC_ID |
43 | 43 | from pyiceberg.table.sorting import INITIAL_SORT_ORDER_ID, SortField, SortOrder |
44 | 44 | from pyiceberg.transforms import BucketTransform, DayTransform, IdentityTransform |
45 | | -from pyiceberg.typedef import Identifier |
46 | 45 | from pyiceberg.types import IntegerType, LongType, NestedField, TimestampType, UUIDType |
47 | 46 | from tests.conftest import clean_up |
48 | 47 |
|
@@ -641,6 +640,7 @@ def test_rest_custom_namespace_separator(rest_catalog: RestCatalog, table_schema |
641 | 640 | loaded_table = rest_catalog.load_table(identifier=full_table_identifier_tuple) |
642 | 641 | assert loaded_table.name() == full_table_identifier_tuple |
643 | 642 |
|
| 643 | + |
644 | 644 | @pytest.mark.integration |
645 | 645 | @pytest.mark.parametrize("test_catalog", CATALOGS) |
646 | 646 | def test_incompatible_partitioned_schema_evolution( |
@@ -671,6 +671,7 @@ def test_incompatible_partitioned_schema_evolution( |
671 | 671 | assert table.spec() == PartitionSpec(PartitionField(2, 1001, DayTransform(), "tpep_pickup_day"), spec_id=1) |
672 | 672 | assert table.schema() == Schema(NestedField(2, "tpep_pickup_datetime", TimestampType(), False)) |
673 | 673 |
|
| 674 | + |
674 | 675 | @pytest.mark.integration |
675 | 676 | @pytest.mark.parametrize("test_catalog", CATALOGS) |
676 | 677 | def test_namespace_with_slash(test_catalog: Catalog) -> None: |
@@ -715,6 +716,7 @@ def test_incompatible_sorted_schema_evolution( |
715 | 716 | NestedField(1, "VendorID", IntegerType(), False), NestedField(2, "tpep_pickup_datetime", TimestampType(), False) |
716 | 717 | ) |
717 | 718 |
|
| 719 | + |
718 | 720 | def test_namespace_with_dot(test_catalog: Catalog) -> None: |
719 | 721 | if isinstance(test_catalog, (HiveCatalog, SqlCatalog)): |
720 | 722 | pytest.skip(f"{type(test_catalog).__name__} does not support dot in namespace") |
|
0 commit comments