re_run_aba_2024.py

import os
import sys

sys.path.append(os.path.dirname(sys.path[0]))
from utils.DolphinschedulerHelper import DolphinschedulerHelper
from utils.common_util import CommonUtil


if __name__ == '__main__':
    date_list = ['2024-01', '2024-02', '2024-03', '2024-04',
                 '2024-05', '2024-06', '2024-07', '2024-08']
    for date_info in date_list:
        print(f"当前执行的分区为：{date_info}")
        success_flag = DolphinschedulerHelper.start_and_watch_process_instance(
            "big_data_selection",
            process_df_name='ABA品牌标签调整重跑_api',
            startParams={
                "site_name": "us",
                "date_type": "month",
                "date_info": date_info,
                "wx_user": "chenyuanjie"
            }
        )
        if success_flag:
            continue
        else:
            CommonUtil.send_wx_msg(["chenyuanjie"], f"ABA品牌标签调整重跑_api {date_info} 执行失败")
            break

    CommonUtil.send_wx_msg(["chenyuanjie"], "ABA品牌标签调整重跑_api 2024年 执行结束")

    pass