Renamings

tests/tpch/duckdb_queries.py

@@ -1,4 +1,4 @@
-def query_1(connection, dataset_path, scale):
+def query_01(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with lineitem as (
@@ -30,7 +30,7 @@ def query_1(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_2(connection, dataset_path, scale):
+def query_02(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with part as (select * from read_parquet('{dataset_path}part/*.parquet')),
@@ -87,7 +87,7 @@ def query_2(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_3(connection, dataset_path, scale):
+def query_03(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with customer as (select * from read_parquet('{dataset_path}customer/*.parquet')),
@@ -121,7 +121,7 @@ def query_3(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_4(connection, dataset_path, scale):
+def query_04(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with orders as (select * from read_parquet('{dataset_path}orders/*.parquet')),
@@ -152,7 +152,7 @@ def query_4(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_5(connection, dataset_path, scale):
+def query_05(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with customer as (select * from read_parquet('{dataset_path}customer/*.parquet')),
@@ -190,7 +190,7 @@ def query_5(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_6(connection, dataset_path, scale):
+def query_06(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with lineitem as (
@@ -210,7 +210,7 @@ def query_6(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_7(connection, dataset_path, scale):
+def query_07(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with supplier as (select * from read_parquet('{dataset_path}supplier/*.parquet')),
@@ -262,7 +262,7 @@ def query_7(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_8(connection, dataset_path, scale):
+def query_08(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with part as (select * from read_parquet('{dataset_path}part/*.parquet')),
@@ -317,7 +317,7 @@ def query_8(connection, dataset_path, scale):
     ).arrow()
 
 
-def query_9(connection, dataset_path, scale):
+def query_09(connection, dataset_path, scale):
     return connection.execute(
         f"""
         with part as (select * from read_parquet('{dataset_path}part/*.parquet')),

tests/tpch/test_duckdb.py

@@ -46,63 +46,63 @@ def _():
     return _
 
 
-def test_query_1(run, connection, dataset_path, scale):
+def test_query_01(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_1(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_2(run, connection, dataset_path, scale):
+def test_query_02(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_2(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_3(run, connection, dataset_path, scale):
+def test_query_03(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_3(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_4(run, connection, dataset_path, scale):
+def test_query_04(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_4(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_5(run, connection, dataset_path, scale):
+def test_query_05(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_5(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_6(run, connection, dataset_path, scale):
+def test_query_06(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_6(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_7(run, connection, dataset_path, scale):
+def test_query_07(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_7(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_8(run, connection, dataset_path, scale):
+def test_query_08(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_8(connection(), dataset_path, scale)
 
     run(_)
 
 
-def test_query_9(run, connection, dataset_path, scale):
+def test_query_09(run, connection, dataset_path, scale):
     def _():
         duckdb_queries.query_9(connection(), dataset_path, scale)
 

tests/tpch/test_polars.py

@@ -45,7 +45,7 @@ def read_data(filename):
         return pl.scan_parquet(fileglob)
 
 
-def test_query_1(run, restart, dataset_path):
+def test_query_01(run, restart, dataset_path):
     def _():
         var_1 = datetime(1998, 9, 2)
         q = read_data(dataset_path + "lineitem")
@@ -78,7 +78,7 @@ def _():
     run(_)
 
 
-def test_query_2(run, restart, dataset_path):
+def test_query_02(run, restart, dataset_path):
     def _():
         var_1 = 15
         var_2 = "BRASS"
@@ -131,7 +131,7 @@ def _():
     run(_)
 
 
-def test_query_3(run, restart, dataset_path):
+def test_query_03(run, restart, dataset_path):
     def _():
         var_1 = var_2 = datetime(1995, 3, 15)
         var_3 = "BUILDING"
@@ -168,7 +168,7 @@ def _():
     run(_)
 
 
-def test_query_4(run, restart, dataset_path):
+def test_query_04(run, restart, dataset_path):
     def _():
         var_1 = datetime(1993, 7, 1)
         var_2 = datetime(1993, 10, 1)
@@ -190,7 +190,7 @@ def _():
     run(_)
 
 
-def test_query_5(run, restart, dataset_path):
+def test_query_05(run, restart, dataset_path):
     def _():
         var_1 = "ASIA"
         var_2 = datetime(1994, 1, 1)
@@ -228,7 +228,7 @@ def _():
     run(_)
 
 
-def test_query_6(run, restart, dataset_path):
+def test_query_06(run, restart, dataset_path):
     def _():
         var_1 = datetime(1994, 1, 1)
         var_2 = datetime(1995, 1, 1)
@@ -251,7 +251,7 @@ def _():
     run(_)
 
 
-def test_query_7(run, restart, dataset_path):
+def test_query_07(run, restart, dataset_path):
     def _():
         nation_ds = read_data(dataset_path + "nation")
         customer_ds = read_data(dataset_path + "customer")
@@ -300,7 +300,7 @@ def _():
     run(_)
 
 
-def test_query_8(run, restart, dataset_path):
+def test_query_08(run, restart, dataset_path):
     def _():
         part_ds = read_data(dataset_path + "part")
         supplier_ds = read_data(dataset_path + "supplier")
@@ -352,7 +352,7 @@ def _():
     run(_)
 
 
-def test_query_9(run, restart, dataset_path):
+def test_query_09(run, restart, dataset_path):
     def _():
         part_ds = read_data(dataset_path + "part")
         supplier_ds = read_data(dataset_path + "supplier")

tests/tpch/test_pyspark.py

@@ -162,7 +162,7 @@ def register_table(spark, path, name):
     df.createOrReplaceTempView(name)
 
 
-def test_query_1(spark, dataset_path):
+def test_query_01(spark, dataset_path):
     register_table(spark, dataset_path, "lineitem")
 
     query = """select
@@ -190,7 +190,7 @@ def test_query_1(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_2(spark, dataset_path):
+def test_query_02(spark, dataset_path):
     for name in ("part", "supplier", "partsupp", "nation", "region"):
         register_table(spark, dataset_path, name)
 
@@ -244,7 +244,7 @@ def test_query_2(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_3(spark, dataset_path):
+def test_query_03(spark, dataset_path):
     for name in ("customer", "orders", "lineitem"):
         register_table(spark, dataset_path, name)
 
@@ -277,7 +277,7 @@ def test_query_3(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_4(spark, dataset_path):
+def test_query_04(spark, dataset_path):
     for name in ("orders", "lineitem"):
         register_table(spark, dataset_path, name)
 
@@ -308,7 +308,7 @@ def test_query_4(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_5(spark, dataset_path):
+def test_query_05(spark, dataset_path):
     for name in (
         "customer",
         "orders",
@@ -348,7 +348,7 @@ def test_query_5(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_6(spark, dataset_path):
+def test_query_06(spark, dataset_path):
     for name in ("lineitem",):
         register_table(spark, dataset_path, name)
 
@@ -367,7 +367,7 @@ def test_query_6(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_7(spark, dataset_path):
+def test_query_07(spark, dataset_path):
     for name in ("supplier", "lineitem", "orders", "customer", "nation"):
         register_table(spark, dataset_path, name)
 
@@ -416,7 +416,7 @@ def test_query_7(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_8(spark, dataset_path):
+def test_query_08(spark, dataset_path):
     for name in (
         "part",
         "supplier",
@@ -473,7 +473,7 @@ def test_query_8(spark, dataset_path):
     spark.sql(query).collect()
 
 
-def test_query_9(spark, dataset_path):
+def test_query_09(spark, dataset_path):
     for name in ("part", "supplier", "lineitem", "partsupp", "orders", "nation"):
         register_table(spark, dataset_path, name)