修改_hcg属性的判断方式

Author: zty-king

python/paddle/distributed/auto_parallel/process_mesh.py

@@ -392,7 +392,7 @@ def get_group(
                     f"{dim_name} not in the dimension names {self._dim_names}"
                 )
             else:
-                if not fleet._hybrid_communicate_group_is_None():
+                if hasattr(fleet.fleet, "_hcg"):
                     hcg = fleet.get_hybrid_communicate_group()
                     if hcg is not None:
 

python/paddle/distributed/fleet/__init__.py

@@ -53,7 +53,6 @@
 ]
 
 fleet = Fleet()
-_hybrid_communicate_group_is_None = fleet._hybrid_communicate_group_is_None
 _final_strategy = fleet._final_strategy
 _get_applied_meta_list = fleet._get_applied_meta_list
 _get_applied_graph_list = fleet._get_applied_graph_list

python/paddle/distributed/fleet/fleet.py

@@ -212,7 +212,6 @@ def __init__(self) -> None:
         self._is_collective = False
         self._runtime_handle = None
         self._util = None
-        self._hcg = None
         self._context = {}
         self.user_defined_optimizer: Optimizer = paddle.optimizer.Optimizer(0.0)
 
@@ -741,9 +740,6 @@ def get_hybrid_communicate_group(self) -> HybridCommunicateGroup:
         assert self._hcg is not None
         return self._hcg
 
-    def _hybrid_communicate_group_is_None(self) -> bool:
-        return self._hcg is None
-
     def get_hybrid_parallel_topology(self) -> CommunicateTopology:
         assert self._topology is not None
         return self._topology