Skip to content

Commit 54ce5bc

Browse files
committed
Fix test
1 parent 957e164 commit 54ce5bc

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

tests/integration/helpers/iceberg_utils.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -500,7 +500,7 @@ def default_download_directory(
500500

501501

502502
def execute_spark_query_general(
503-
spark, started_cluster, storage_type: str, table_name: str, query: str, additional_nodes=[]
503+
spark, started_cluster, storage_type: str, table_name: str, query: str, additional_nodes=None
504504
):
505505
spark.sql(query)
506506
default_upload_directory(
@@ -509,6 +509,7 @@ def execute_spark_query_general(
509509
f"/iceberg_data/default/{table_name}/",
510510
f"/iceberg_data/default/{table_name}/",
511511
)
512+
additional_nodes = additional_nodes or []
512513
for node in additional_nodes:
513514
additional_upload_directory(
514515
started_cluster,

0 commit comments

Comments
 (0)