Fix sqlalchemy 2.0

dlt-hub · Oct 2, 2024 · ca04c9d · ca04c9d
1 parent b8a3845
commit ca04c9d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/dlt/destinations/impl/sqlalchemy/merge_job.py b/dlt/destinations/impl/sqlalchemy/merge_job.py
@@ -58,7 +58,7 @@ def gen_merge_sql(
             if len(table_chain) == 1 and not cls.requires_temp_table_for_delete():
                 delete_statement = root_table_obj.delete().where(
                     sa.exists(
-                        sa.select([sa.literal(1)])
+                        sa.select(sa.literal(1))
                         .where(key_clause)
                         .select_from(staging_root_table_obj)
                     )
@@ -81,9 +81,9 @@ def gen_merge_sql(
                 # Insert data into the "temporary" table
                 insert_statement = delete_temp_table.insert().from_select(
                     [row_key_col],
-                    sa.select([row_key_col]).where(
+                    sa.select(row_key_col).where(
                         sa.exists(
-                            sa.select([sa.literal(1)])
+                            sa.select(sa.literal(1))
                             .where(key_clause)
                             .select_from(staging_root_table_obj)
                         )