|
@@ -66,7 +66,6 @@ def carry_plan(user_id, ad_plan_list, log_ad, db, cookie_canuse, task_name):
|
|
|
sql_tools.action_record(res, sql_session, ad_plan_create_action, user_id, plan_name,
|
|
|
action_record_table,
|
|
|
service_name, wechat_name, task_name)
|
|
|
- raise
|
|
|
continue
|
|
|
|
|
|
log_ad.refresh_driver()
|
|
@@ -91,7 +90,6 @@ def carry_plan(user_id, ad_plan_list, log_ad, db, cookie_canuse, task_name):
|
|
|
sql_tools.action_record(res, sql_session, ad_plan_create_action, user_id, plan_name,
|
|
|
action_record_table,
|
|
|
service_name, wechat_name, task_name)
|
|
|
- raise
|
|
|
finally:
|
|
|
log_ad.refresh_driver()
|
|
|
|
|
@@ -100,7 +98,6 @@ def carry_plan(user_id, ad_plan_list, log_ad, db, cookie_canuse, task_name):
|
|
|
sql_tools.update_task_status_error(sql_session=sql_session, user_id=user_id, task_name=task_name)
|
|
|
dingtalk.send_message('user_id:{} 计划执行出错,进行检查\n{}'.format(user_id, str(e)))
|
|
|
logging.error(e)
|
|
|
- raise
|
|
|
finally:
|
|
|
logging.info('创建计划,任务结束')
|
|
|
# 每次运行微信相关操作,对微信相关信息进行刷新
|
|
@@ -209,7 +206,6 @@ def get_human_info(user_id, log_ad, db, cookie_canuse, task_name):
|
|
|
dingtalk.send_message('user_id:{} 获取微信数据出错,进行检查\n{}'.format(user_id, str(e)))
|
|
|
log_ad.refresh_driver()
|
|
|
logging.error(e)
|
|
|
- raise
|
|
|
finally:
|
|
|
logging.info('刷新用户,任务结束')
|
|
|
sql_session.commit()
|