|
|
@@ -30,7 +30,7 @@ EXPLORE_POOL_TABLE = 'alg_growth_video_return_stats_history'
|
|
|
GH_REPLY_STATS_TABLE = 'alg_growth_gh_reply_video_stats'
|
|
|
ODPS_RANK_RESULT_TABLE = 'alg_gh_autoreply_video_rank_data'
|
|
|
RDS_RANK_RESULT_TABLE = 'alg_gh_autoreply_video_rank_data'
|
|
|
-STATS_PERIOD_DAYS = 3
|
|
|
+STATS_PERIOD_DAYS = 5
|
|
|
SEND_N = 2
|
|
|
|
|
|
def check_data_partition(project, table, data_dt, data_hr=None):
|
|
|
@@ -80,7 +80,7 @@ def process_reply_stats(project, table, period, run_dt):
|
|
|
|
|
|
merged_df = pd.concat([df, default_stats_df]).reset_index(drop=True)
|
|
|
|
|
|
- merged_df['score'] = merged_df['day0_return'] / (merged_df['send_count'] + 1000)
|
|
|
+ merged_df['score'] = merged_df['day0_return'] / (merged_df['send_count'] + 500)
|
|
|
return merged_df
|
|
|
|
|
|
|
StrayWarrior