diff --git a/migrations/versions/a650f4061955_.py b/migrations/versions/a650f4061955_.py
index 5a951464..9286153f 100644
--- a/migrations/versions/a650f4061955_.py
+++ b/migrations/versions/a650f4061955_.py
@@ -122,7 +122,7 @@ def upgrade():
     )
     op.create_table('task_event',
     sa.Column('id', sa.Integer(), nullable=False),
-    sa.Column('user_id', sa.String(length=50), nullable=False),
+    sa.Column('user_id', sa.Integer, nullable=False),
     sa.Column('process_instance_id', sa.Integer(), nullable=False),
     sa.Column('spec_version', sa.String(length=50), nullable=True),
     sa.Column('action', sa.String(length=50), nullable=True),
@@ -139,6 +139,7 @@ def upgrade():
     sa.Column('process_name', sa.String(length=50), nullable=True),
     sa.Column('date', sa.DateTime(timezone=True), nullable=True),
     sa.ForeignKeyConstraint(['process_instance_id'], ['process_instance.id'], ),
+    sa.ForeignKeyConstraint(['user_id'], ['user.id'], ),
     sa.PrimaryKeyConstraint('id')
     )
     op.create_table('data_store',
diff --git a/src/spiffworkflow_backend/models/task_event.py b/src/spiffworkflow_backend/models/task_event.py
index 15b1ed7f..339ed458 100644
--- a/src/spiffworkflow_backend/models/task_event.py
+++ b/src/spiffworkflow_backend/models/task_event.py
@@ -35,7 +35,7 @@ class TaskEventModel(SpiffworkflowBaseDBModel):
     __tablename__ = "task_event"
     id = db.Column(db.Integer, primary_key=True)
     user_id = db.Column(
-        db.String(50), nullable=False
+        db.Integer, db.ForeignKey("user.id"), nullable=False
     )  # In some cases the unique user id may not exist in the db yet.
     process_instance_id = db.Column(
         db.Integer, db.ForeignKey("process_instance.id"), nullable=False