diff --git a/db/task_db.py b/db/task_db.py index 7c1feca..af42045 100644 --- a/db/task_db.py +++ b/db/task_db.py @@ -178,9 +178,12 @@ class TaskDBOperator(BaseDBOperator): fields = [] values = [] for key, value in updates.items(): - if key in ['groups', 'content_miniprogram', 'preview_recipients','content_link']: + if key in ['groups', 'content_miniprogram', 'preview_recipients']: fields.append(f"{key} = %s") values.append(value) + elif key == 'content_link' and isinstance(value, dict): + fields.append(f"{key} = %s") + values.append(json.dumps(value)) else: fields.append(f"{key} = %s") values.append(value)