Function _check_work_done

python/pathway/internals/sql/processing.py:641–649

(node: sql_expr.Expression)

def _check_work_done(node: sql_expr.Expression) -> None:
    for key, obj in node.args.items():
        if obj is None:
            continue
        try:
            repr = obj.sql()
        except AttributeError:
            repr = str(obj)
        raise NotImplementedError(f"{key}: {repr} not supported.")