|
36 | 36 | from pyiceberg.transforms import IdentityTransform |
37 | 37 | from pyiceberg.types import BooleanType, DateType, FloatType, IntegerType, LongType, NestedField, StringType, TimestampType |
38 | 38 |
|
39 | | - |
40 | 39 | # Schema and data used by delete_files tests (moved from test_add_files) |
41 | 40 | TABLE_SCHEMA_DELETE_FILES = Schema( |
42 | 41 | NestedField(field_id=1, name="foo", field_type=BooleanType(), required=False), |
@@ -1044,9 +1043,7 @@ def assert_manifest_entry(expected_status: ManifestEntryStatus, expected_snapsho |
1044 | 1043 |
|
1045 | 1044 |
|
1046 | 1045 | @pytest.mark.integration |
1047 | | -def test_delete_files_from_unpartitioned_table( |
1048 | | - spark: SparkSession, session_catalog: Catalog, format_version: int |
1049 | | -) -> None: |
| 1046 | +def test_delete_files_from_unpartitioned_table(spark: SparkSession, session_catalog: Catalog, format_version: int) -> None: |
1050 | 1047 | identifier = f"default.delete_files_unpartitioned_v{format_version}" |
1051 | 1048 | tbl = _create_table_for_delete_files(session_catalog, identifier, format_version) |
1052 | 1049 |
|
@@ -1104,9 +1101,7 @@ def test_delete_files_raises_on_duplicate_paths(session_catalog: Catalog, format |
1104 | 1101 |
|
1105 | 1102 |
|
1106 | 1103 | @pytest.mark.integration |
1107 | | -def test_delete_files_from_branch( |
1108 | | - spark: SparkSession, session_catalog: Catalog, format_version: int |
1109 | | -) -> None: |
| 1104 | +def test_delete_files_from_branch(spark: SparkSession, session_catalog: Catalog, format_version: int) -> None: |
1110 | 1105 | identifier = f"default.delete_files_branch_v{format_version}" |
1111 | 1106 | branch = "branch1" |
1112 | 1107 |
|
|
0 commit comments