fix

Pyspark_job/doris_handle/dwt_flow_asin_week.py

@@ -960,8 +960,8 @@ def modify_mission_record_status(site_name, date_info, result_type):
     df_is_finished = pd.read_sql(select_sql, engine_mysql)
     if df_is_finished.empty:
         replace_sql = f"""
-            replace into {record_table} (site_name, report_date, status, status_val, table_name, date_type, page, is_end, remark, export_db_type)
-            VALUES ('{site_name}', '{date_info}', '{status_remark}', 14, '{table_name_field}', '{date_type}', '流量选品', '是', '{status_remark}', 'doris')
+            replace into {record_table} (site_name, report_date, status, status_val, table_name, date_type, page, is_end, remark, export_db_type, freeze_flag)
+            VALUES ('{site_name}', '{date_info}', '{status_remark}', 14, '{table_name_field}', '{date_type}', '流量选品', '是', '{status_remark}', 'doris', 'prod_disable')
         """
         DBUtil.exec_sql('mysql', 'us', replace_sql)
         print(f"[Step 5] 流程记录表 workflow_everyday 已写入：{site_name} {date_info} date_type={date_type}")
@@ -1004,8 +1004,7 @@ def main(site_name, date_info, result_type='formal'):
     _exec_doris_sql([build_week_insert_overwrite_sql(site_name, week_selection_table, date_info, week_end_date)])
 
     # ===== [Step 5] 流程记录表更新（仅 formal 模式）=====
-    # TODO 待上线后打开
-    # modify_mission_record_status(site_name, date_info, result_type)
+    modify_mission_record_status(site_name, date_info, result_type)
 
     print("success!")
 

Pyspark_job/doris_handle/pinterest_month.py

@@ -236,8 +236,8 @@ def modify_mission_record_status(site_name, date_info, table_name, result_type):
     df_is_finished = pd.read_sql(select_sql, engine_mysql)
     if df_is_finished.empty:
         replace_sql = f"""
-            replace into {record_table} (site_name, report_date, status, status_val, table_name, date_type, page, is_end, remark, export_db_type)
-            VALUES ('{site_name}', '{date_info}', '{status_remark}', 14, '{table_name}', '{date_type}', 'pinterest', '是', '{status_remark}', 'doris')
+            replace into {record_table} (site_name, report_date, status, status_val, table_name, date_type, page, is_end, remark, export_db_type, freeze_flag)
+            VALUES ('{site_name}', '{date_info}', '{status_remark}', 14, '{table_name}', '{date_type}', 'pinterest', '是', '{status_remark}', 'doris', 'prod_disable')
         """
         DBUtil.exec_sql('mysql', 'us', replace_sql)
         print(f"[Step 3] 流程记录表 workflow_everyday 已写入：{site_name} {date_info} table_name={table_name}")
@@ -263,8 +263,7 @@ def main(site_name, date_info, result_type='formal'):
     _exec_doris_sql([build_month_insert_overwrite_sql(site_name, month_table, date_info)])
 
     # ===== [Step 3] 流程记录表更新（仅 formal 模式）=====
-    # TODO 待上线后打开
-    # modify_mission_record_status(site_name, date_info, month_table, result_type)
+    modify_mission_record_status(site_name, date_info, month_table, result_type)
 
     print("success!")