@@ -444,29 +444,20 @@ def dump_results_to_csv(
444444 timestamp (str): time when results were taken
445445 logger (logging.Logger): instance of logger
446446 """
447- fieldnames = ["nodename" , "plugin" , "status" , "timestamp" , "message" , "analysis_results " ]
447+ fieldnames = ["nodename" , "plugin" , "status" , "timestamp" , "message" , "analysis_result " ]
448448 filename = log_path + "/nodescraper.csv"
449449 all_rows = []
450450 for res in results :
451- if res .status .name == "OK" :
452- row = {
453- "nodename" : nodename ,
454- "plugin" : res .source ,
455- "status" : res .status .name ,
456- "timestamp" : timestamp ,
457- "message" : res .message ,
458- "analysis_results" : "" ,
459- }
460- else :
461- row = {
462- "nodename" : nodename ,
463- "plugin" : res .source ,
464- "status" : res .status .name ,
465- "timestamp" : timestamp ,
466- "message" : res .message ,
467- "analysis_results" : res .result_data .analysis_result ,
468- }
451+ row = {
452+ "nodename" : nodename ,
453+ "plugin" : res .source ,
454+ "status" : res .status .name ,
455+ "timestamp" : timestamp ,
456+ "message" : res .message ,
457+ "analysis_result" : "" if res .status .name == "OK" else res .result_data .analysis_result ,
458+ }
469459 all_rows .append (row )
460+
470461 dump_to_csv (all_rows , filename , fieldnames , logger )
471462
472463
@@ -499,7 +490,7 @@ def generate_summary(search_path: str, output_path: str | None, logger: logging.
499490 logger (logging.Logger): instance of logger
500491 """
501492
502- fieldnames = ["nodename" , "plugin" , "status" , "timestamp" , "message" , "analysis_results " ]
493+ fieldnames = ["nodename" , "plugin" , "status" , "timestamp" , "message" , "analysis_result " ]
503494 all_rows = []
504495
505496 pattern = os .path .join (search_path , "**" , "nodescraper.csv" )
0 commit comments