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 31cf1ad9ff184d840ec16b9b636fbc3555728980..4fa9f53c623e07f2e508b1bce2e262bc13541cfd 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 49b7d560ee8bdd486172df5b26589a4a213a4dce..7990aefd411c3283a0d8d6de8a46143a78d66026 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) + ")"]