【发布时间】:2021-10-19 00:22:23
【问题描述】:
我在一个数据块笔记本的 10 个数据块单元格中有 phyton 代码。
第一个单元格包含以下代码。
df = spark.sql(f"""select * from test.table """)
count= df.count()
这里如果 count 为 0 ,我希望笔记本失败,如果 count 大于 1 ,我希望 databricks 笔记本中的其余单元格执行。
我正在尝试下面的代码。
df = spark.sql(f"""select * from test.table """)
count= df.count()
assert count <= 0
上面的代码没有引发断言错误,而是说查询不返回任何结果并执行数据块中的下一个单元格。有人可以让我知道引发断言异常并终止笔记本而不执行更多单元格。
谢谢。
【问题讨论】:
标签: python pyspark databricks