diff --git a/octavia/db/migration/alembic_migrations/versions/29ff921a6eb_shared_pools.py b/octavia/db/migration/alembic_migrations/versions/29ff921a6eb_shared_pools.py
index e1778423b7..93c8b1ead3 100644
--- a/octavia/db/migration/alembic_migrations/versions/29ff921a6eb_shared_pools.py
+++ b/octavia/db/migration/alembic_migrations/versions/29ff921a6eb_shared_pools.py
@@ -54,8 +54,8 @@ def upgrade():
                             sa.ForeignKey('load_balancer.id'), nullable=True))
 
     # Populate this new column appropriately
-    select_obj = sa.select([listener.c.load_balancer_id,
-                           listener.c.default_pool_id]).where(
+    select_obj = sa.select(listener.c.load_balancer_id,
+                           listener.c.default_pool_id).where(
                                listener.c.default_pool_id is not None)
     result = conn.execute(select_obj)
     for row in result:
diff --git a/octavia/db/migration/alembic_migrations/versions/dcf88e59aae4_add_lb_algorithm_source_ip_port.py b/octavia/db/migration/alembic_migrations/versions/dcf88e59aae4_add_lb_algorithm_source_ip_port.py
index f61cdcc786..5ceff64f3b 100644
--- a/octavia/db/migration/alembic_migrations/versions/dcf88e59aae4_add_lb_algorithm_source_ip_port.py
+++ b/octavia/db/migration/alembic_migrations/versions/dcf88e59aae4_add_lb_algorithm_source_ip_port.py
@@ -43,7 +43,7 @@ def migrate_pools():
 
     j = pool_table.join(lb_table,
                         pool_table.c.load_balancer_id == lb_table.c.id)
-    stmt = sa.select([pool_table.c.id]).select_from(j).where(
+    stmt = sa.select(pool_table.c.id).select_from(j).where(
         lb_table.c.provider == 'ovn')
     result = conn.execute(stmt)