diff --git a/alembic/versions/ceb5976b37dd_add_swap_jit_liquidity_join_table.py b/alembic/versions/ceb5976b37dd_add_swap_jit_liquidity_join_table.py
index a9f8c02..3f51e7b 100644
--- a/alembic/versions/ceb5976b37dd_add_swap_jit_liquidity_join_table.py
+++ b/alembic/versions/ceb5976b37dd_add_swap_jit_liquidity_join_table.py
@@ -16,7 +16,7 @@ depends_on = None
 
 
 def upgrade():
-    sa.create_table(
+    op.create_table(
         "jit_liquidity_swaps",
         sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
         sa.Column("jit_liquidity_id", sa.String(1024), primary_key=True),