mv need_sync scope

PaddlePaddle · Jul 30, 2021 · d249d45 · d249d45 · paddle-bot-old · Jul 30, 2021
1 parent 86cdb5c
commit d249d45
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/python/paddle/distributed/fleet/elastic.py b/python/paddle/distributed/fleet/elastic.py
@@ -133,6 +133,7 @@ def __init__(self, args):
         self.stopped = False
 
         self.sigint = 0
+        self.need_sync = False
 
         if not server or ':' not in server or not name or not np:
             logger.info(
@@ -172,8 +173,6 @@ def __init__(self, args):
         # register watch to reset host after host been deleted
         self.etcd.delete_prefix(self.node_prefix)
 
-        self.need_sync = False
-
         def host_call_back(event):
             if self.etcd.get(self.host_path)[0] == None:
                 logger.info('register host again {}'.format(self.host))