Skip to content

Commit 3423b27

Browse files
georgesittasCopilot
andcommitted
Update sqlglot/schema.py
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
1 parent 464d349 commit 3423b27

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

sqlglot/schema.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -572,8 +572,12 @@ def _normalize_udf(
572572

573573
if isinstance(udf, str):
574574
parsed: exp.Expression = exp.maybe_parse(udf, dialect=dialect)
575-
udf = parsed if isinstance(parsed, exp.Anonymous) else parsed.this
575+
udf_expr = parsed.expression if isinstance(parsed, exp.Dot) else None
576576

577+
if not isinstance(udf_expr, exp.Anonymous):
578+
raise SchemaError(f"Unable to parse UDF from: {udf!r}")
579+
580+
udf = udf_expr
577581
parts = self.udf_parts(udf)
578582

579583
if normalize:

0 commit comments

Comments
 (0)