no message

Pyspark_job/sqoop_export/export_dwt_asin_sync.py

 import os
 import sys
 import time
+import traceback
 
 sys.path.append(os.path.dirname(sys.path[0]))
 from utils.secure_db_client import get_remote_engine
@@ -54,9 +55,10 @@ def update_workflow_manager(site_name, date_type, date_info):
                     """
                     print(f"workflow_manager进度表---重置爬虫的asin抓取进度: {update_sql_workflow}")
                     conn.execute(update_sql_workflow)
+                    break
             except Exception as e:
+                print(f"失败：workflow_manager进度表---重置爬虫的asin抓取进度: {update_sql_workflow}, {e}, 报错信息: {traceback.format_exc()}")
                 time.sleep(300)
-
                 continue
 
 
@@ -97,5 +99,5 @@ if __name__ == '__main__':
     date_type = sys.argv[2]  # 参数2：类型：week/4_week/month/quarter/day
     date_info = sys.argv[3]  # 参数3：年-周/年-月/年-季/年-月-日, 比如: 2022-1
     export_data(site_name, date_type, date_info)
-    if site_name in ["us", "uk", "de"] and date_type == "month":
-        update_workflow_manager(site_name, date_type, date_info)
+    # if site_name in ["us", "uk", "de"] and date_type == "month":
+    #     update_workflow_manager(site_name, date_type, date_info)