diff --git a/task_management/all_task_management.py b/task_management/all_task_management.py index f560324..ef1dd7c 100644 --- a/task_management/all_task_management.py +++ b/task_management/all_task_management.py @@ -67,7 +67,7 @@ class AllTask: try: params = {"task_id": data["task_id"]} where_conditions = "task_id = %s" - affected_rows = await self.db_pool.update(table='crawler_account_record_info', set_columns={"status": data["status"]}, + affected_rows = await self.db_pool.update(table='crawler_task_record_info', set_columns={"status": data["status"]}, where_conditions=where_conditions, params=params) if affected_rows: print(f"task_id{data['task_id']} 任务完成,任务状态已修改成功")