|
|
@@ -239,9 +239,9 @@ def rank_for_base(run_dt, run_hour, rank_table):
|
|
|
|
|
|
stats_with_strategy_df = stats_df \
|
|
|
.merge(
|
|
|
- base_strategy_df,
|
|
|
- on=['gh_id', 'video_id'],
|
|
|
- how='left') \
|
|
|
+ base_strategy_df,
|
|
|
+ on=['gh_id', 'video_id'],
|
|
|
+ how='outer') \
|
|
|
.query('strategy_key.notna() or score > 0.1')
|
|
|
|
|
|
# 合并default和分账号数据
|
|
|
@@ -351,7 +351,7 @@ def main_loop():
|
|
|
return
|
|
|
except Exception as e:
|
|
|
LOGGER.error(f"数据更新失败, exception: {e}, traceback: {traceback.format_exc()}")
|
|
|
- if CONFIG.ENV_TEXT == '开发环境':
|
|
|
+ if CONFIG.ENV_TEXT == '开发环境' or args.dry_run:
|
|
|
return
|
|
|
send_msg_to_feishu(
|
|
|
webhook=CONFIG.FEISHU_ROBOT['growth_task_robot'].get('webhook'),
|
