Skip to content

Commit c5a8e21

Browse files
committed
remove xfail for 13110
1 parent 560a529 commit c5a8e21

2 files changed

Lines changed: 2 additions & 3 deletions

File tree

integration_tests/src/main/python/delta_lake_liquid_clustering_test.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,7 +210,6 @@ def write_func(spark, path):
210210
reason="Delta Lake liquid clustering is only supported on Databricks 13.3+")
211211
@pytest.mark.skipif(not is_spark_353_or_later(),
212212
reason="Create table with cluster by is only supported on delta 3.1+")
213-
@pytest.mark.xfail(reason="https://github.com/NVIDIA/spark-rapids/issues/13110")
214213
def test_delta_insert_overwrite_dynamic_sql_liquid_clustering(spark_tmp_path,
215214
spark_tmp_table_factory):
216215
def write_func(spark, path):

integration_tests/src/main/python/delta_lake_write_test.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -431,7 +431,7 @@ def setup_tables(spark):
431431
@pytest.mark.skipif(is_before_spark_320(), reason="Delta Lake writes are not supported before Spark 3.2.x")
432432
@pytest.mark.parametrize("mode", [
433433
"STATIC",
434-
pytest.param("DYNAMIC", marks=pytest.mark.xfail(reason="https://github.com/NVIDIA/spark-rapids/issues/9543 (DB), https://github.com/NVIDIA/spark-rapids/issues/13110 (OSS)"))
434+
pytest.param("DYNAMIC", marks=pytest.mark.xfail(condition=is_databricks_runtime(), reason="https://github.com/NVIDIA/spark-rapids/issues/9543"))
435435
], ids=idfn)
436436
@pytest.mark.parametrize("clause", ["", "PARTITION (id)"], ids=idfn)
437437
def test_delta_overwrite_dynamic_missing_clauses(spark_tmp_table_factory, spark_tmp_path, mode, clause):
@@ -454,7 +454,7 @@ def setup(spark):
454454
@pytest.mark.skipif(is_before_spark_320(), reason="Delta Lake writes are not supported before Spark 3.2.x")
455455
@pytest.mark.parametrize("mode", [
456456
"STATIC",
457-
pytest.param("DYNAMIC", marks=pytest.mark.xfail(reason="https://github.com/NVIDIA/spark-rapids/issues/9543 (DB), https://github.com/NVIDIA/spark-rapids/issues/13110 (OSS)"))
457+
pytest.param("DYNAMIC", marks=pytest.mark.xfail(condition=is_databricks_runtime(), reason="https://github.com/NVIDIA/spark-rapids/issues/9543"))
458458
], ids=idfn)
459459
@pytest.mark.parametrize("clause", ["PARTITION (id, p = 2)", "PARTITION (p = 2, id)", "PARTITION (p = 2)"])
460460
def test_delta_overwrite_mixed_clause(spark_tmp_table_factory, spark_tmp_path, mode, clause):

0 commit comments

Comments
 (0)