Skip to content

Commit 242ea1a

Browse files
committed
refactor
1 parent dda7a20 commit 242ea1a

1 file changed

Lines changed: 3 additions & 6 deletions

File tree

sqlglot/optimizer/annotate_types.py

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -336,23 +336,20 @@ def _get_scope_selects(self, scope: Scope) -> dict[str, dict[str, t.Any]]:
336336
field_col = field.this
337337

338338
first = seq_get(field.expressions, 0)
339-
if not first:
340-
continue
341-
342-
is_pivot_alias = isinstance(first, exp.PivotAlias)
343339

344340
# FOR column type from the alias literal, or VARCHAR if no alias
345-
if is_pivot_alias:
341+
if isinstance(first, exp.PivotAlias):
346342
alias_node = first.args.get("alias")
347343
if alias_node:
348344
col_types[field_col.name] = alias_node.type
345+
src = first.this
349346
else:
350347
col_types[field_col.name] = exp.DataType.build(
351348
"VARCHAR", dialect=self.dialect
352349
)
350+
src = first
353351

354352
# Value column types from the IN source columns
355-
src = first.this if is_pivot_alias else first
356353
src_cols = src.expressions if isinstance(src, exp.Tuple) else [src]
357354
for val_expr in pivot.expressions:
358355
val_cols = (

0 commit comments

Comments
 (0)