Skip to content

Commit acd56f5

Browse files
authored
add diagnostic assertions
1 parent d8882e4 commit acd56f5

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

hail/hail/src/is/hail/expr/ir/TableValue.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1058,6 +1058,7 @@ case class TableValue(ctx: ExecuteContext, typ: TableType, globals: BroadcastRow
10581058
val newType = typ.copy(rowType = extracted.postAggIR.typ.asInstanceOf[TStruct])
10591059

10601060
if (extracted.aggs.isEmpty) {
1061+
assert(false)
10611062
val (Some(PTypeReferenceSingleCodeType(rTyp)), f) =
10621063
Compile[AsmFunction3RegionLongLongLong](
10631064
ctx,
@@ -1195,6 +1196,7 @@ case class TableValue(ctx: ExecuteContext, typ: TableType, globals: BroadcastRow
11951196
}
11961197

11971198
if (ctx.getFlag("distributed_scan_comb_op") != null && extracted.shouldTreeAggregate) {
1199+
assert(false)
11981200
val fsBc = ctx.fs.broadcast
11991201
val tmpBase = ctx.createTmpPath("table-map-rows-distributed-scan")
12001202
val d = digitsNeeded(rvd.getNumPartitions)

0 commit comments

Comments
 (0)