File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1414# KIND, either express or implied. See the License for the
1515# specific language governing permissions and limitations
1616# under the License.
17- import math
1817
1918from pyspark .sql import SparkSession
2019from pyspark .sql .functions import current_date , date_add , expr
2827
2928
3029catalogs = {
31- ' rest' : load_catalog (
30+ " rest" : load_catalog (
3231 "rest" ,
3332 ** {
3433 "type" : "rest" ,
3837 "s3.secret-access-key" : "password" ,
3938 },
4039 ),
41- ' hive' : load_catalog (
40+ " hive" : load_catalog (
4241 "hive" ,
4342 ** {
4443 "type" : "hive" ,
111110 # v3: Using deletion vectors
112111
113112 for format_version in [2 , 3 ]:
114- identifier = f' { catalog_name } .default.test_positional_mor_deletes_v{ format_version } '
113+ identifier = f" { catalog_name } .default.test_positional_mor_deletes_v{ format_version } "
115114 spark .sql (
116115 f"""
117116 CREATE OR REPLACE TABLE { identifier } (
156155
157156 spark .sql (f"DELETE FROM { identifier } WHERE number = 9" )
158157
159- identifier = f' { catalog_name } .default.test_positional_mor_double_deletes_v{ format_version } '
158+ identifier = f" { catalog_name } .default.test_positional_mor_double_deletes_v{ format_version } "
160159
161160 spark .sql (
162161 f"""
Original file line number Diff line number Diff line change 1616# under the License.
1717
1818src = [' pyiceberg' ,' tests' ]
19- extend-exclude = [" dev/provision.py" ]
2019
2120# Exclude a variety of commonly ignored directories.
2221exclude = [
You can’t perform that action at this time.
0 commit comments