From a7ce8bc80cff96afbe240e7cc7df1e711358815a Mon Sep 17 00:00:00 2001 From: z30043230 Date: Fri, 4 Jul 2025 15:56:50 +0800 Subject: [PATCH] =?UTF-8?q?bugfix:group=5Fname=E6=9C=89=E5=8F=AF=E8=83=BD?= =?UTF-8?q?=E4=B8=BA=E7=A9=BA=E5=AD=97=E7=AC=A6=E4=B8=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../communication_group/base_communication_group.py | 2 -- .../recipes/communication_group_map/communication_group_map.py | 2 -- 2 files changed, 4 deletions(-) diff --git a/profiler/msprof_analyze/cluster_analyse/communication_group/base_communication_group.py b/profiler/msprof_analyze/cluster_analyse/communication_group/base_communication_group.py index 31cf1ad9ff1..4fa9f53c623 100644 --- a/profiler/msprof_analyze/cluster_analyse/communication_group/base_communication_group.py +++ b/profiler/msprof_analyze/cluster_analyse/communication_group/base_communication_group.py @@ -196,8 +196,6 @@ class BaseCommunicationGroup: group_name = str(double_hash(group_id)) # group_name is hashed group_id pg_name = parallel_info.get("group_name", "") global_ranks = parallel_info.get("global_ranks", []) - if not pg_name or not global_ranks: - continue parallel_group_df.loc[parallel_group_df.shape[0]] = [group_name, group_id, pg_name, global_ranks] # merge by group_name diff --git a/profiler/msprof_analyze/cluster_analyse/recipes/communication_group_map/communication_group_map.py b/profiler/msprof_analyze/cluster_analyse/recipes/communication_group_map/communication_group_map.py index 49b7d560ee8..7990aefd411 100644 --- a/profiler/msprof_analyze/cluster_analyse/recipes/communication_group_map/communication_group_map.py +++ b/profiler/msprof_analyze/cluster_analyse/recipes/communication_group_map/communication_group_map.py @@ -119,8 +119,6 @@ class CommunicationGroupMap(BaseRecipeAnalysis): group_name = str(double_hash(group_id)) # group_name is hashed group_id pg_name = parallel_info.get(TableConstant.GROUP_NAME, "") global_ranks = parallel_info.get(self.GLOBAL_RANKS, []) - if not pg_name or not global_ranks: - continue parallel_info_df.loc[parallel_info_df.shape[0]] = [group_name, group_id, pg_name, "(" + ",".join(str(i) for i in global_ranks) + ")"] -- Gitee