

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

dataset/ETHPy150Open blaze/blaze/blaze/expr/tests/test_split.py test_distinct/VarMisuse@55/65 `chunk`->`agg_expr`