no message

Pyspark_job/listen_program/wf_month_control.py

@@ -63,6 +63,7 @@ ansible dabing_all -f 10 -m shell -a "nohup /usr/local/bin/python3 /mnt/py_spide
                     spider_script,
                     spider_is_ready,
                     spider_state,
+                    kafka_state,
                     bg_name,
                     bg_dol_name,
                     bg_dol_state
@@ -78,6 +79,7 @@ ansible dabing_all -f 10 -m shell -a "nohup /usr/local/bin/python3 /mnt/py_spide
                     '{spider_script}',
                     'yes',
                     1,
+                    1,
                     '{bg_name}', 
                     '{bg_dol_name}',
                     1
@@ -87,7 +89,8 @@ ansible dabing_all -f 10 -m shell -a "nohup /usr/local/bin/python3 /mnt/py_spide
                     spider_is_ready = VALUES(spider_is_ready), 
                     spider_script = VALUES(spider_script), 
                     bg_dol_state = VALUES(bg_dol_state), 
-                    spider_state = VALUES(spider_state);
+                    spider_state = VALUES(spider_state), 
+                    kafka_state = VALUES(kafka_state);
                 """
         print(f"workflow_manager进度表---重置进度: {update_sql_workflow}")
         engine_mysql.execute(update_sql_workflow)