diff --git a/migrations/20240327_add_created_and_origin.py b/migrations/20240327_add_created_and_origin.py
index a20c8de30ba56357497ecd83f09ea92b3fe01e5a..728696d4cf35db5e67aca6be8531a8b1e6e77813 100644
--- a/migrations/20240327_add_created_and_origin.py
+++ b/migrations/20240327_add_created_and_origin.py
@@ -35,7 +35,7 @@ def upgrade():
         for row in reader:
             if row[0] in users:
                 users[row[0]]["created"] = fromisoformat(row[1][:-3])
-                users[row[0]]["origin"] = row[2]
+                users[row[0]]["created_source"] = row[2]
 
     # Add copy created column from last_update if they are not in csv file
     for username in users:
@@ -43,13 +43,13 @@ def upgrade():
             users[username]["created"] = fromisoformat(
                 users[username]["last_update"]
             )
-            users[username]["origin"] = "last_update"
+            users[username]["created_source"] = "last_update"
         # No need to update this column back to the db
         del users[username]["last_update"]
 
     # Create new columns
     table.create_column("created", db.types.datetime)
-    table.create_column("origin", db.types.text)
+    table.create_column("created_source", db.types.text)
 
     # Update database in chunk
     table.update_many(list(users.values()), ["username"], ensure=True)