任务编排，测试通过

Pyspark_job/listen_program/import_st_to_pg14.py

@@ -187,6 +187,7 @@ class ImportStToPg14(object):
                         spider_is_ready,
                         spider_state,
                         bg_name,
+                        bg_dol_name,
                         bg_dol_state
                     )
                     VALUES
@@ -201,6 +202,7 @@ class ImportStToPg14(object):
                         'yes',
                         1,
                         '{self.site_name}_asin_export', 
+                        'ALL站点-asin同步-pg-api',
                         1
                     )
                     ON DUPLICATE KEY UPDATE

Pyspark_job/sqoop_export/export_dwt_asin_sync.py

@@ -36,6 +36,7 @@ def update_workflow_manager(site_name, date_type, date_info):
                                         spider_is_ready,
                                         spider_state,
                                         bg_name,
+                                        bg_dol_name, 
                                         bg_dol_state,
                                         finished_count
                                     )
@@ -51,13 +52,15 @@ def update_workflow_manager(site_name, date_type, date_info):
                                         'yes',
                                         1,
                                         '{site_name}_all_cal', 
+                                        'ALL-月流程-ABA+反查+流量选品', 
                                         1,
                                         0
                                     )
                                     ON DUPLICATE KEY UPDATE
                                         spider_is_ready = VALUES(spider_is_ready),
                                         spider_script = VALUES(spider_script),
-                                        spider_state = VALUES(spider_state);
+                                        spider_state = VALUES(spider_state),
+                                        bg_dol_name = VALUES(bg_dol_name);
                             """
                 print(f"workflow_manager进度表---重置爬虫的asin抓取进度: {update_sql_workflow_spider}")
                 engine_mysql.execute(update_sql_workflow_spider)