From 19ba2156a9fd0f8ea71f39576f82599cdc58e601 Mon Sep 17 00:00:00 2001 From: fanxiaotong Date: Wed, 27 Sep 2023 16:25:12 +0800 Subject: [PATCH 1/2] fix bug --- .../cluster_kernels_analysis/cluster_prof_Info_analysis.py | 1 + 1 file changed, 1 insertion(+) diff --git a/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py b/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py index dd4cc20464..4742d3919f 100644 --- a/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py +++ b/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py @@ -57,6 +57,7 @@ class FormDataProcessor: df['node_id'] = self.getNodeId(f) # 将数据添加到最终的数据框中 + all_data = all_data.append(df, ignore_index=True) return all_data -- Gitee From 1a279bf90a1f6895674fa4896ebc13c0750f2686 Mon Sep 17 00:00:00 2001 From: fanxiaotong Date: Wed, 27 Sep 2023 16:32:02 +0800 Subject: [PATCH 2/2] fix bug --- .../cluster_prof_Info_analysis.py | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py b/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py index 4742d3919f..3b2b05676d 100644 --- a/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py +++ b/profiler/cluster_analyse/cluster_kernels_analysis/cluster_prof_Info_analysis.py @@ -21,9 +21,8 @@ import re import plotly.graph_objects as go from plotly.subplots import make_subplots from plotly.offline import plot -from threading import Thread import os -import json + import warnings @@ -182,15 +181,9 @@ class StatisticalInfoToHtmlAnalyzer(OpSummaryAnalyzerBase): self.top_n = min(max(self.top_n, 1), len(view_data)) top_n_data = view_data.sort_values(("Task Duration(us)", 'var'), ascending=False).head(self.top_n) - threads = [] for column in self.columns_to_view: # 分别给每一种特性画图 - draw_thread = Thread(target=self.drawPloty, args=(column, summary_data, top_n_data, rank_num)) - threads.append(draw_thread) - draw_thread.start() - - for draw_thread in threads: - draw_thread.join() + self.drawPloty(column, summary_data, top_n_data, rank_num) def drawPloty(self, column, summary_data, top_n_data, rank_num): col_num = self.getCalNum(rank_num) -- Gitee