|
@@ -27,6 +27,8 @@ EXPLORE2_GROUP_NAME = '3rd-party-explore2'
|
|
|
# GH_IDS will be updated by get_and_update_gh_ids
|
|
|
GH_IDS = ('default',)
|
|
|
|
|
|
+pd.set_option('display.max_rows', None)
|
|
|
+
|
|
|
TARGET_GH_IDS = (
|
|
|
'gh_250c51d5ce69',
|
|
|
'gh_8a29eebc2012',
|
|
@@ -307,9 +309,9 @@ def build_and_transfer_data(run_dt, run_hour, project, **kwargs):
|
|
|
gh_df = get_and_update_gh_ids(run_dt)
|
|
|
|
|
|
layer1_rank = rank_for_layer1(run_dt, run_hour, ODS_PROJECT, EXPLORE_POOL_TABLE, gh_df)
|
|
|
- # layer2_rank = rank_for_layer2(run_dt, run_hour, ODS_PROJECT, GH_REPLY_STATS_TABLE, ODPS_RANK_RESULT_TABLE)
|
|
|
+ layer2_rank = rank_for_layer2(run_dt, run_hour, ODS_PROJECT, GH_REPLY_STATS_TABLE, ODPS_RANK_RESULT_TABLE)
|
|
|
# base_rank = rank_for_base(run_dt, run_hour, ODS_PROJECT, GH_REPLY_STATS_TABLE, ODPS_RANK_RESULT_TABLE,BASE_GROUP_NAME)
|
|
|
- layer2_rank = rank_for_base_designate(run_dt, run_hour, EXPLORE2_GROUP_NAME)
|
|
|
+ # layer2_rank = rank_for_base_designate(run_dt, run_hour, EXPLORE2_GROUP_NAME)
|
|
|
base_rank = rank_for_base_designate(run_dt, run_hour, BASE_GROUP_NAME)
|
|
|
|
|
|
final_rank_df = pd.concat([layer1_rank, layer2_rank, base_rank]).reset_index(drop=True)
|