diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-08 08:11:53 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-08 08:12:02 +0000 |
| commit | 8d36f5966675e23bee7026ba37ae0647fbf47300 (patch) | |
| tree | df4227bbb3b07cb70df87237bcff03c8efd7822d /sqlglot/executor/python.py | |
| parent | Releasing debian version 22.2.0-1. (diff) | |
| download | sqlglot-8d36f5966675e23bee7026ba37ae0647fbf47300.tar.xz sqlglot-8d36f5966675e23bee7026ba37ae0647fbf47300.zip | |
Merging upstream version 23.7.0.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'sqlglot/executor/python.py')
| -rw-r--r-- | sqlglot/executor/python.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sqlglot/executor/python.py b/sqlglot/executor/python.py index a2b23d4..674ef78 100644 --- a/sqlglot/executor/python.py +++ b/sqlglot/executor/python.py @@ -157,7 +157,7 @@ class PythonExecutor: yield context.table.reader def join(self, step, context): - source = step.name + source = step.source_name source_table = context.tables[source] source_context = self.context({source: source_table}) @@ -398,7 +398,7 @@ def _lambda_sql(self, e: exp.Lambda) -> str: lambda n: ( exp.var(n.name) if isinstance(n, exp.Identifier) and n.name.lower() in names else n ) - ) + ).assert_is(exp.Lambda) return f"lambda {self.expressions(e, flat=True)}: {self.sql(e, 'this')}" |