

def test_reductions():
    ((chunk, chunk_expr), (agg, agg_expr)) = split(t, t.amount.nunique())
    assert (chunk.schema == t.schema)
    assert chunk_expr.isidentical(chunk.amount.distinct())
    assert isscalar(agg_expr.dshape.measure)
    assert agg_expr.isidentical(agg.distinct().count())
    ((chunk, chunk_expr), (agg, agg_expr)) = split(t, t.amount.nunique(keepdims=True))
    assert (chunk.schema == t.schema)
    assert chunk_expr.isidentical(chunk.amount.distinct())
    assert isscalar(agg.dshape.measure)
    assert agg_expr.isidentical(agg.distinct().count(keepdims=True))

dataset/ETHPy150Open blaze/blaze/blaze/expr/tests/test_split.py test_reductions/VarMisuse@64/79 `agg`->`agg_expr`