diff --git a/migrations/versions/20260502_0014_v1_api_schema.py b/migrations/versions/20260502_0014_v1_api_schema.py
index e9bc383..bccb34b 100644
--- a/migrations/versions/20260502_0014_v1_api_schema.py
+++ b/migrations/versions/20260502_0014_v1_api_schema.py
@@ -57,7 +57,7 @@ def upgrade() -> None:
     if not _table_exists(inspector, "broker_credentials"):
         op.create_table(
             "broker_credentials",
-            sa.Column("user_id", sa.Integer(), nullable=False),
+            sa.Column("user_id", sa.Text(), nullable=False),
             sa.Column("broker", sa.Text(), nullable=False),
             sa.Column("account_ref", sa.Text(), nullable=False),
             sa.Column("encrypted_payload", sa.Text(), nullable=False),