no message

Pyspark_job/sqoop_export/dwd_day_asin.py

@@ -2,7 +2,7 @@ import os
 import sys
 
 sys.path.append(os.path.dirname(sys.path[0]))
-from utils.ssh_util import SSHUtil
+
 from utils.common_util import CommonUtil
 from utils.db_util import DBUtil
 

Pyspark_job/sqoop_export/dwd_st_volume_fba.py

@@ -116,9 +116,8 @@ if __name__ == '__main__':
                            target_tb_name=export_tb_before,
                            cp_index_flag=True)
         update_workflow_sql = f"""
-                    replace INTO selection.workflow_everyday
-                    (site_name, report_date, status, status_val, table_name, date_type, page, is_end, remark,export_db_type)
-                    VALUES('{site_name}', '{datetime.now().date()}', '导出PG数据库完成', 14, 'us_aba_last_30_day', '30_day', 'ABA搜索词', '是', 'ABA搜索词最近30天表','{db_type}');
+            replace INTO selection.workflow_everyday (site_name, report_date, status, status_val, table_name, date_type, page, is_end, remark, export_db_type)
+            VALUES('{site_name}', '{datetime.now().date()}', '导出PG数据库完成', 14, 'us_aba_last_30_day', '30_day', 'ABA搜索词', '是', 'ABA搜索词最近30天表', '{db_type}');
         """
     else:
         update_workflow_sql = f"""