diff --git a/ibis/backends/base/sql/alchemy/query_builder.py b/ibis/backends/base/sql/alchemy/query_builder.py index 2873ab006e0d..641d80ac1bd7 100644 --- a/ibis/backends/base/sql/alchemy/query_builder.py +++ b/ibis/backends/base/sql/alchemy/query_builder.py @@ -58,12 +58,12 @@ def get_result(self): elif jtype is ops.OuterJoin: result = result.outerjoin(table, onclause, full=True) elif jtype is ops.LeftSemiJoin: - result = sa.select([result]).where( - sa.exists(sa.select([1]).where(onclause)) + result = result.select().where( + sa.exists(sa.select(1).where(onclause)) ) elif jtype is ops.LeftAntiJoin: - result = sa.select([result]).where( - ~(sa.exists(sa.select([1]).where(onclause))) + result = result.select().where( + ~sa.exists(sa.select(1).where(onclause)) ) else: raise NotImplementedError(jtype)