no message

Pyspark_job/listen_program/site_search_term_to_syn.py

@@ -91,22 +91,30 @@ class Integrate_search_term():
 
             with self.engine_mysql.begin() as conn:
                 update_sql_workflow = f"""
-                                            INSERT INTO workflow_manager
+                                        INSERT INTO workflow_manager
                         (
+                            workflow_name,
                             site_name,
                             date_type,
                             date_info,
+                            priority,
                             spider_name,
                             spider_is_ready,
-                            spider_state
+                            spider_state,
+                            bg_name,
+                            bg_dol_state
                         )
                         VALUES
                         (
+                            '月全流程',
                             '{self.site_name}',
                             'month',
                             '{self.date_info}',
+                            1,
                             'us_spider_st',
                             'yes',
+                            1,
+                            'us_asin_export', 
                             1
                         )
                         ON DUPLICATE KEY UPDATE