This is an automated email from the ASF dual-hosted git repository. fokko pushed a commit to branch pyiceberg-0.6.x in repository https://gitbox.apache.org/repos/asf/iceberg-python.git
commit 929d0b42ee8e2aa21fbb14bdcac423c4b65f9cef Author: HonahX <hon...@apache.org> AuthorDate: Sat Apr 13 15:07:46 2024 -0700 fix lint issue --- pyiceberg/catalog/glue.py | 2 +- tests/integration/test_writes.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/pyiceberg/catalog/glue.py b/pyiceberg/catalog/glue.py index 97393881..291c0667 100644 --- a/pyiceberg/catalog/glue.py +++ b/pyiceberg/catalog/glue.py @@ -62,7 +62,7 @@ from pyiceberg.io import load_file_io from pyiceberg.partitioning import UNPARTITIONED_PARTITION_SPEC, PartitionSpec from pyiceberg.schema import Schema, SchemaVisitor, visit from pyiceberg.serializers import FromInputFile -from pyiceberg.table import CommitTableRequest, CommitTableResponse, Table, update_table_metadata, PropertyUtil +from pyiceberg.table import CommitTableRequest, CommitTableResponse, PropertyUtil, Table, update_table_metadata from pyiceberg.table.metadata import TableMetadata, new_table_metadata from pyiceberg.table.sorting import UNSORTED_SORT_ORDER, SortOrder from pyiceberg.typedef import EMPTY_DICT, Identifier, Properties diff --git a/tests/integration/test_writes.py b/tests/integration/test_writes.py index f1612b49..873966ca 100644 --- a/tests/integration/test_writes.py +++ b/tests/integration/test_writes.py @@ -32,7 +32,6 @@ from pyspark.sql import SparkSession from pytest_mock.plugin import MockerFixture from pyiceberg.catalog import Catalog, load_catalog -from pyiceberg.catalog import Catalog from pyiceberg.catalog.hive import HiveCatalog from pyiceberg.catalog.sql import SqlCatalog from pyiceberg.exceptions import NamespaceAlreadyExistsError, NoSuchTableError @@ -667,6 +666,7 @@ def test_duckdb_url_import(warehouse: Path, arrow_table_with_null: pa.Table) -> ), ] + @pytest.mark.integration @pytest.mark.parametrize("format_version", [1, 2]) def test_hive_catalog_storage_descriptor( @@ -677,7 +677,7 @@ def test_hive_catalog_storage_descriptor( format_version: int, ) -> None: tbl = _create_table( - session_catalog_hive, "default.test_storage_descriptor", {"format-version": format_version}, [arrow_table_with_null] + session_catalog_hive, "default.test_storage_descriptor", {"format-version": str(format_version)}, [arrow_table_with_null] ) # check if pyiceberg can read the table