[CodeStyle][E711] use is/is not for comparison with None (#47452)

* [CodeStyle][E711] use `is`/`is not` for comparison with `None`

* `self.assertTrue($A is None)` -> `self.assertIsNone($A)`

* `self.assertTrue($A is not None)` -> `self.assertIsNotNone($A)`

* `self.assertFalse($A is None)` -> `self.assertIsNotNone($A)`

* `self.assertEqual($A, None)` -> `self.assertIsNone($A)`

* `self.assertNotEqual($A, None)` -> `self.assertIsNotNone($A)`

Author: SigureMo

paddle/scripts/conda_build.py

@@ -171,7 +171,7 @@ def meta_build_mac(var, python_str, paddle_version, build_var, build_name_str):
 def meta_build_linux(
     var, python_str, paddle_version, build_var, build_name_str, cuda_str=None
 ):
-    if cuda_str == None:
+    if cuda_str is None:
         package_str = (
             """
 package:
@@ -192,7 +192,7 @@ def meta_build_linux(
     )
     meta_build = var.build + build_name_str
     meta_str = package_str + meta_build + requirement
-    if not (cuda_str == None):
+    if not (cuda_str is None):
         meta_str = meta_str + cuda_str
     meta_str = meta_str + var.test + var.about
 
@@ -209,7 +209,7 @@ def meta_build_linux(
 def meta_build_windows(
     var, python_str, paddle_version, blt_var, build_name_str, cuda_str=None
 ):
-    if cuda_str == None:
+    if cuda_str is None:
         package_str = (
             """
 package:
@@ -235,7 +235,7 @@ def meta_build_windows(
     meta_build = var.build + build_name_str
     meta_str = package_str + meta_build + requirement
 
-    if not (cuda_str == None):
+    if not (cuda_str is None):
         meta_str = meta_str + cuda_str
 
     blt_str = var.blt_const + blt_var

python/paddle/cost_model/cost_model.py

@@ -74,7 +74,7 @@ def static_cost_data(self):
 
     def get_static_op_time(self, op_name, forward=True, dtype="float32"):
         # if forward is True, return op forward time, otherwise return op backward time.
-        if op_name == None:
+        if op_name is None:
             raise ValueError(
                 'op_name should not be empty when you want to get static op time'
             )

python/paddle/dataset/imdb.py

@@ -45,7 +45,7 @@ def tokenize(pattern):
         # tarfile.extractfile, which does random access and might
         # destroy hard disks.
         tf = tarf.next()
-        while tf != None:
+        while tf is not None:
             if bool(pattern.match(tf.name)):
                 # newline and punctuations removal and ad-hoc tokenization.
                 yield tarf.extractfile(tf).read().rstrip(b'\n\r').translate(

python/paddle/dataset/tests/imdb_test.py

@@ -31,13 +31,13 @@ class TestIMDB(unittest.TestCase):
     word_idx = None
 
     def test_build_dict(self):
-        if self.word_idx == None:
+        if self.word_idx is None:
             self.word_idx = paddle.dataset.imdb.build_dict(TRAIN_PATTERN, 150)
 
         self.assertEqual(len(self.word_idx), 7036)
 
     def check_dataset(self, dataset, expected_size):
-        if self.word_idx == None:
+        if self.word_idx is None:
             self.word_idx = paddle.dataset.imdb.build_dict(TRAIN_PATTERN, 150)
 
         sum = 0

python/paddle/distributed/auto_parallel/cost/base_cost.py

@@ -587,7 +587,7 @@ def get_max_beta(self, ranks):
                         if forward_order_beta > backward_order_beta
                         else backward_order_beta
                     )
-                    if max_beta == None:
+                    if max_beta is None:
                         max_beta = beta
                     else:
                         if beta > max_beta:

python/paddle/distributed/auto_parallel/partitioner.py

@@ -84,7 +84,7 @@ def partition(
         dist_op_context.rank_id = self._rank_id
 
         # partition startup program
-        if serial_startup_program == None:
+        if serial_startup_program is None:
             partitioned_startup_prog = None
         else:
             partitioned_startup_prog = self.partition_startup_program(

python/paddle/distributed/auto_parallel/process_group.py

@@ -61,7 +61,7 @@ def new_process_group(ranks, group_id=None):
     num_groups = len(_g_process_group_map)
     # Note: our process group may interfere with the original implementation
     # so the created group id should start from the original _new_ring_id()
-    if group_id == None:
+    if group_id is None:
         group_id = _new_ring_id() + num_groups + 1
 
     new_pg = ProcessGroup(group_id, ranks)

python/paddle/distributed/auto_parallel/tuner/optimization_tuner.py

@@ -530,7 +530,7 @@ def _update(self, i, trial, results):
         self._finished_trials.append(trial)
 
         cur_mertic = get_metric(results)
-        if self._best_metric == None or cur_mertic > self._best_metric:
+        if self._best_metric is None or cur_mertic > self._best_metric:
             self._best_metric = cur_mertic
             self._best_iter = i
 

python/paddle/distributed/elastic.py

@@ -31,7 +31,7 @@ def set_np(self, np):
         self.etcd.put(self.np_path, '{}'.format(np).encode('latin-1'))
 
     def scale_np(self, np):
-        if self.etcd.get(self.np_path)[0] != None:
+        if self.etcd.get(self.np_path)[0] is not None:
             self.set_np(np)
             return True
         return False

python/paddle/distributed/fleet/base/role_maker.py

@@ -293,7 +293,7 @@ def __get_default_iface_from_gateway(self):
             if "Gateway" in item and "Iface" in item:
                 gateway_idx = item.index("Gateway")
                 iface_idx = item.index("Iface")
-            elif gateway_idx != None and iface_idx != None:
+            elif gateway_idx is not None and iface_idx is not None:
                 gateway = None
                 if len(item) > gateway_idx:
                     gateway = item[gateway_idx]
@@ -845,7 +845,7 @@ def _ps_env(self):  # each role will execute it
         self._server_endpoints = self._server_endpoints.split(",")
 
         self._worker_endpoints = os.getenv("PADDLE_TRAINER_ENDPOINTS", None)
-        if self._worker_endpoints != None:
+        if self._worker_endpoints is not None:
             self._worker_endpoints = self._worker_endpoints.split(",")
         else:
             self._worker_endpoints = []
@@ -860,14 +860,14 @@ def _ps_env(self):  # each role will execute it
             self._coordinator_endpoints = self._coordinator_endpoints.split(",")
 
         trainers_num = os.getenv("PADDLE_TRAINERS_NUM", None)
-        if trainers_num == None:
+        if trainers_num is None:
             raise ValueError(
                 "Can not find PADDLE_TRAINERS_NUM, please check your environment."
             )
         trainers_num = int(trainers_num)
 
         training_role = os.getenv("TRAINING_ROLE", None)
-        if training_role == None:
+        if training_role is None:
             raise ValueError(
                 "Can not find TRAINING_ROLE, please check your environment."
             )
@@ -937,39 +937,39 @@ def _ps_env(self):  # each role will execute it
         if training_role == "TRAINER":
             role = Role.WORKER
             current_id = os.getenv("PADDLE_TRAINER_ID", None)
-            if current_id == None:
+            if current_id is None:
                 raise ValueError(
                     "Can not find PADDLE_TRAINER_ID, please check your environment."
                 )
             current_id = int(current_id)
             if self._is_heter_parameter_server_mode:
                 self._stage_id = os.getenv("STAGE_ID", None)
-                if self._stage_id == None:
+                if self._stage_id is None:
                     raise ValueError(
                         "Can not find STAGE_ID, please check your environment."
                     )
                 self._stage_id = int(self._stage_id)
                 self._stage_num = os.getenv("STAGE_NUM", None)
-                if self._stage_num == None:
+                if self._stage_num is None:
                     raise ValueError(
                         "Can not find STAGE_NUM, please check your environment."
                     )
                 self._stage_num = int(self._stage_num)
                 self._stage_trainers = os.getenv(
                     "PADDLE_STAGE_TRAINERS_NUM", None
                 )
-                if self._stage_trainers == None:
+                if self._stage_trainers is None:
                     raise ValueError(
                         "Can not find PADDLE_STAGE_TRAINERS_NUM, please check your environment."
                     )
                 self._stage_trainers = eval(self._stage_trainers)
             cur_port = os.getenv("PADDLE_PORT", None)
-            if cur_port == None:
+            if cur_port is None:
                 raise ValueError(
                     "Can not find PADDLE_PORT, please check your environment."
                 )
             cur_ip = os.getenv("POD_IP", None)
-            if cur_ip == None:
+            if cur_ip is None:
                 raise ValueError(
                     "Can not find POD_IP, please check your environment."
                 )
@@ -982,12 +982,12 @@ def _ps_env(self):  # each role will execute it
         elif training_role == "PSERVER":
             role = Role.SERVER
             cur_port = os.getenv("PADDLE_PORT", None)
-            if cur_port == None:
+            if cur_port is None:
                 raise ValueError(
                     "Can not find PADDLE_PORT, please check your environment."
                 )
             cur_ip = os.getenv("POD_IP", None)
-            if cur_ip == None:
+            if cur_ip is None:
                 raise ValueError(
                     "Can not find POD_IP, please check your environment."
                 )
@@ -997,20 +997,20 @@ def _ps_env(self):  # each role will execute it
         elif training_role == "HETER_TRAINER":
             role = Role.HETER_WORKER
             self._stage_id = os.getenv("STAGE_ID", None)
-            if self._stage_id == None:
+            if self._stage_id is None:
                 raise ValueError(
                     "Can not find STAGE_ID, please check your environment."
                 )
             self._stage_id = int(self._stage_id)
             self._stage_num = os.getenv("STAGE_NUM", None)
-            if self._stage_num == None:
+            if self._stage_num is None:
                 raise ValueError(
                     "Can not find STAGE_NUM, please check your environment."
                 )
             self._stage_num = int(self._stage_num)
 
             self._stage_trainers = os.getenv("PADDLE_STAGE_TRAINERS_NUM", None)
-            if self._stage_trainers == None:
+            if self._stage_trainers is None:
                 raise ValueError(
                     "Can not find PADDLE_STAGE_TRAINERS_NUM, please check your environment."
                 )
@@ -1019,7 +1019,7 @@ def _ps_env(self):  # each role will execute it
             self._heter_trainer_device_type = os.getenv(
                 "HETER_DEVICE_TYPE", None
             )
-            if self._heter_trainer_device_type == None:
+            if self._heter_trainer_device_type is None:
                 raise ValueError(
                     "Can not find HETER_DEVICE_TYPE, please check your environment."
                 )
@@ -1040,12 +1040,12 @@ def _ps_env(self):  # each role will execute it
                 )
 
             cur_port = os.getenv("PADDLE_PORT", None)
-            if cur_port == None:
+            if cur_port is None:
                 raise ValueError(
                     "Can not find PADDLE_PORT, please check your environment."
                 )
             cur_ip = os.getenv("POD_IP", None)
-            if cur_ip == None:
+            if cur_ip is None:
                 raise ValueError(
                     "Can not find POD_IP, please check your environment."
                 )