fix: worker: source → channel für DB-Kompatibilität
This commit is contained in:
+2
-2
@@ -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,
|
||||
|
||||
Reference in New Issue
Block a user