diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-06-30 08:03:58 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-06-30 08:03:58 +0000 |
| commit | 9f19773cebdc9476f2a3266d3c01c967c38fcd1e (patch) | |
| tree | a60f607ba2bb64fb45da86c297ff29ffc9b92f58 /sqlglot/executor/python.py | |
| parent | Releasing debian version 16.7.3-1. (diff) | |
| download | sqlglot-9f19773cebdc9476f2a3266d3c01c967c38fcd1e.tar.xz sqlglot-9f19773cebdc9476f2a3266d3c01c967c38fcd1e.zip | |
Merging upstream version 16.7.7.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'sqlglot/executor/python.py')
| -rw-r--r-- | sqlglot/executor/python.py | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/sqlglot/executor/python.py b/sqlglot/executor/python.py index a927181..34a380e 100644 --- a/sqlglot/executor/python.py +++ b/sqlglot/executor/python.py @@ -19,7 +19,6 @@ class PythonExecutor: self.tables = tables or {} def execute(self, plan): - running = set() finished = set() queue = set(plan.leaves) contexts = {} @@ -34,7 +33,6 @@ class PythonExecutor: for name, table in contexts[dep].tables.items() } ) - running.add(node) if isinstance(node, planner.Scan): contexts[node] = self.scan(node, context) @@ -49,11 +47,10 @@ class PythonExecutor: else: raise NotImplementedError - running.remove(node) finished.add(node) for dep in node.dependents: - if dep not in running and all(d in contexts for d in dep.dependencies): + if all(d in contexts for d in dep.dependencies): queue.add(dep) for dep in node.dependencies: |