Revert "no message"

This reverts commit a9047c6a.

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,10 @@ 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"""
                 UPDATE selection.workflow_everyday SET status='导出PG数据库完成', status_val=14,is_end ='是',export_db_type = '{db_type}'