diff --git a/queue_worker.py b/queue_worker.py
index fe8654a..317fe02 100644
--- a/queue_worker.py
+++ b/queue_worker.py
@@ -96,7 +96,7 @@ def process_whatsapp_submission(db: sqlite3.Connection, payload: dict) -> str:
 
                     db.execute(
                         """INSERT INTO submissions
-                           (sender_id, sender_name, source, type, content, payload_json, created_at)
+                           (sender_id, sender_name, channel, type, content, payload_json, created_at)
                            VALUES (?, ?, ?, ?, ?, ?, ?)""",
                         (
                             sender_id,
@@ -153,7 +153,7 @@ def process_telegram_submission(db: sqlite3.Connection, payload: dict) -> str:
 
         db.execute(
             """INSERT INTO submissions
-               (sender_id, sender_name, source, type, content, payload_json, created_at)
+               (sender_id, sender_name, channel, type, content, payload_json, created_at)
                VALUES (?, ?, ?, ?, ?, ?, ?)""",
             (
                 sender_id,