Skip to content
This repository was archived by the owner on Mar 16, 2026. It is now read-only.

Commit 455dbeb

Browse files
committed
Fixed broken code in last merged main, as we need to avoid duplicate entries and potential implicit joins due to identical table names
1 parent 3c50f7d commit 455dbeb

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

sqlalchemy_bigquery/base.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -275,7 +275,8 @@ def _known_tables(self):
275275
asfrom_froms = self.stack[-1].get("asfrom_froms", [])
276276
for from_ in asfrom_froms:
277277
if isinstance(from_, Table):
278-
known_tables.add(from_.name)
278+
if from_.name not in known_tables:
279+
known_tables.add(from_.name)
279280

280281
return known_tables
281282

0 commit comments

Comments
 (0)