

@dispatch(Sub)
def _subexpr_optimize(expr):
    new_expr = type(expr)(*map(_subexpr_optimize, expr._args))
    schema = expr.schema
    if (isinstance(expr, TimeDelta) and (schema.unit != 'ns')):
        new_expr = new_expr.coerce(timedelta_ns)
    return new_expr

dataset/ETHPy150Open blaze/blaze/blaze/compute/sql.py _subexpr_optimize/VarMisuse@44/56 `schema`->`expr`