Skip to content

Commit 1e8e8fc

Browse files
committed
Remove DBR check
1 parent 8d36a70 commit 1e8e8fc

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

integration_tests/src/main/python/delta_lake_test.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -178,9 +178,7 @@ def create_delta(spark):
178178

179179
def read_table(spark):
180180
df = spark.sql(f"SELECT * FROM delta.`{data_path}`")
181-
explain_string = df._sc._jvm.PythonSQLUtils.explainString(df._jdf.queryExecution(), "extended")
182-
assert "__delta_internal_is_row_deleted" in explain_string or \
183-
"_databricks_internal_edge_computed_column_skip_row" in explain_string
181+
assert "__delta_internal_is_row_deleted" in df._sc._jvm.PythonSQLUtils.explainString(df._jdf.queryExecution(), "extended")
184182
return df
185183

186184
with_cpu_session(create_delta)

0 commit comments

Comments
 (0)