|
@@ -332,7 +332,8 @@ def build_and_transfer_data(run_dt, run_hour, project, **kwargs):
|
|
|
final_df['sort'] = SEND_N + 1 - final_df['sort']
|
|
|
|
|
|
if dry_run:
|
|
|
- print(final_df[['strategy_key', 'gh_id', 'sort', 'video_id', 'score', 'title']])
|
|
|
+ print(final_df[['strategy_key', 'gh_id', 'sort', 'video_id', 'score', 'title']]
|
|
|
+ .sort_values(by=['strategy_key', 'gh_id', 'sort']))
|
|
|
return
|
|
|
|
|
|
# save to ODPS
|