Apply ruff/Perflint rule PERF401

PERF401 Use a list comprehension to create a transformed list

Author: DimitriPapadopoulos

tests/test_executors.py

@@ -18,9 +18,7 @@ def run_pool_test(self, pool_factory):
         async def run():
             pool = pool_factory()
             with pool:
-                coros = []
-                for i in range(0, 10):
-                    coros.append(self.loop.run_in_executor(pool, fib, i))
+                coros = [self.loop.run_in_executor(pool, fib, i) for i in range(0, 10)]
                 res = await asyncio.gather(*coros)
             self.assertEqual(res, fib10)
             await asyncio.sleep(0.01)

tests/test_tcp.py

@@ -124,9 +124,7 @@ async def start_server():
 
             addr = srv_socks[0].getsockname()
 
-            tasks = []
-            for _ in range(TOTAL_CNT):
-                tasks.append(test_client(addr))
+            tasks = [test_client(addr) for _ in range(TOTAL_CNT)]
 
             await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -168,9 +166,7 @@ async def start_server_sock():
             self.assertTrue(srv_socks)
             self.assertTrue(srv.is_serving())
 
-            tasks = []
-            for _ in range(TOTAL_CNT):
-                tasks.append(test_client(addr))
+            tasks = [test_client(addr) for _ in range(TOTAL_CNT)]
 
             await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -472,9 +468,7 @@ def run(coro):
             with self.tcp_server(server,
                                  max_clients=TOTAL_CNT,
                                  backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(asyncio.gather(*tasks))
 
@@ -529,9 +523,7 @@ def run(coro):
             with self.tcp_server(server,
                                  max_clients=TOTAL_CNT,
                                  backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(asyncio.gather(*tasks))
 
@@ -628,9 +620,7 @@ async def start_server():
 
             addr = srv_socks[0].getsockname()
 
-            tasks = []
-            for _ in range(TOTAL_CNT):
-                tasks.append(test_client(addr))
+            tasks = [test_client(addr) for _ in range(TOTAL_CNT)]
 
             await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -1337,9 +1327,7 @@ async def start_server():
 
                 addr = srv_socks[0].getsockname()
 
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(test_client(addr))
+                tasks = [test_client(addr) for _ in range(TOTAL_CNT)]
 
                 await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -1433,9 +1421,7 @@ def run(coro):
             with self.tcp_server(server,
                                  max_clients=TOTAL_CNT,
                                  backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(asyncio.gather(*tasks))
 
@@ -2207,9 +2193,7 @@ async def start_server():
 
                 addr = srv_socks[0].getsockname()
 
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(test_client(addr))
+                tasks = [test_client(addr) for _ in range(TOTAL_CNT)]
 
                 await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -2329,9 +2313,7 @@ def run(coro):
             with self.tcp_server(server,
                                  max_clients=TOTAL_CNT,
                                  backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(
                     asyncio.gather(*tasks))
@@ -2422,9 +2404,7 @@ async def start_server():
 
                 addr = srv_socks[0].getsockname()
 
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(test_client(addr))
+                tasks = [test_client(addr) for _ in range(TOTAL_CNT)]
 
                 await asyncio.wait_for(
                     asyncio.gather(*tasks),
@@ -2494,9 +2474,7 @@ def run(coro):
             with self.tcp_server(server,
                                  max_clients=TOTAL_CNT,
                                  backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(
                     asyncio.gather(*tasks))

tests/test_unix.py

@@ -71,9 +71,7 @@ async def start_server():
                     self.assertTrue(srv_socks)
                     self.assertTrue(srv.is_serving())
 
-                    tasks = []
-                    for _ in range(TOTAL_CNT):
-                        tasks.append(test_client(sock_name))
+                    tasks = [test_client(sock_name) for _ in range(TOTAL_CNT)]
 
                     await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -123,9 +121,7 @@ async def start_server_sock(start_server, is_unix_api=True):
                     self.assertTrue(srv_socks)
                     self.assertTrue(srv.is_serving())
 
-                    tasks = []
-                    for _ in range(TOTAL_CNT):
-                        tasks.append(test_client(sock_name))
+                    tasks = [test_client(sock_name) for _ in range(TOTAL_CNT)]
 
                     await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -282,9 +278,7 @@ def run(coro):
             with self.unix_server(server,
                                   max_clients=TOTAL_CNT,
                                   backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(asyncio.gather(*tasks))
 
@@ -343,9 +337,7 @@ def run(coro):
             with self.unix_server(server,
                                   max_clients=TOTAL_CNT,
                                   backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(asyncio.gather(*tasks))
 
@@ -610,9 +602,7 @@ async def start_server():
                     **extras)
 
                 try:
-                    tasks = []
-                    for _ in range(TOTAL_CNT):
-                        tasks.append(test_client(sock_name))
+                    tasks = [test_client(sock_name) for _ in range(TOTAL_CNT)]
 
                     await asyncio.wait_for(asyncio.gather(*tasks), TIMEOUT)
 
@@ -686,9 +676,7 @@ def run(coro):
             with self.unix_server(server,
                                   max_clients=TOTAL_CNT,
                                   backlog=TOTAL_CNT) as srv:
-                tasks = []
-                for _ in range(TOTAL_CNT):
-                    tasks.append(coro(srv.addr))
+                tasks = [coro(srv.addr) for _ in range(TOTAL_CNT)]
 
                 self.loop.run_until_complete(asyncio.gather(*tasks))