Function _run

python/pathway/internals/sql/processing.py:40–44

(node: sql_expr.Expression, context: ContextType)

def _run(node: sql_expr.Expression, context: ContextType) -> Any:
    handler = _expression_handlers.get(type(node))
    if handler is None:
        raise NotImplementedError(f"{node.sql()} not supported.")
    return handler(node, context)


def register(nodetype):