代码优化
This commit is contained in:
parent
b66978ce2f
commit
36a0a133c4
|
|
@ -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']} 任务完成,任务状态已修改成功")
|
||||
|
|
|
|||
Loading…
Reference in New Issue