Apply ruff rule RUF046

RUF046 Value being cast to `int` is already an integer

Author: DimitriPapadopoulos

setup.py

@@ -119,12 +119,16 @@ def finalize_options(self):
                 import Cython
             except ImportError:
                 raise RuntimeError(
-                    f'please install {CYTHON_DEPENDENCY} to compile uvloop from source')
+                    f'please install {CYTHON_DEPENDENCY} to compile uvloop '
+                    'from source'
+                )
 
             cython_dep = Requirement(CYTHON_DEPENDENCY)
             if not cython_dep.specifier.contains(Cython.__version__):
                 raise RuntimeError(
-                    f'uvloop requires {CYTHON_DEPENDENCY}, got Cython=={Cython.__version__}')
+                    f'uvloop requires {CYTHON_DEPENDENCY}, '
+                    f'got Cython=={Cython.__version__}'
+                )
 
             from Cython.Build import cythonize
 

tests/test_base.py

@@ -215,9 +215,9 @@ def cb():
 
         for i in range(8):
             self.loop.call_later(0.06 + 0.01, cb)  # 0.06999999999999999
-            started = int(round(self.loop.time() * 1000))
+            started = round(self.loop.time() * 1000)
             self.loop.run_forever()
-            finished = int(round(self.loop.time() * 1000))
+            finished = round(self.loop.time() * 1000)
             self.assertGreaterEqual(finished - started, 69)
 
     def test_call_at(self):

tests/test_context.py

@@ -61,7 +61,9 @@ def get_buffer(self, sizehint):
         if self.buffered_ctx is None:
             self.buffered_ctx = self.cvar.get()
         elif self.cvar.get() != self.buffered_ctx:
-            self.data_received_fut.set_exception(ValueError(f"{self.buffered_ctx} != {self.cvar.get()}"))
+            self.data_received_fut.set_exception(
+                ValueError(f"{self.buffered_ctx} != {self.cvar.get()}")
+            )
         return bytearray(65536)
 
     def buffer_updated(self, nbytes):

tests/test_executors.py

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

uvloop/__init__.py

@@ -204,7 +204,8 @@ def get_event_loop(self) -> _AbstractEventLoop:
             """
             if self._local._loop is None:
                 raise RuntimeError(
-                    f'There is no current event loop in thread {threading.current_thread().name!r}.'
+                    'There is no current event loop in '
+                    f'thread {threading.current_thread().name!r}.'
                 )
 
             return self._local._loop

uvloop/_testbase.py

@@ -52,8 +52,8 @@ def __new__(mcls, name, bases, dct):
             for base in bases:
                 if hasattr(base, test_name):
                     raise RuntimeError(
-                        f'duplicate test {name}.{test_name} (also defined in {base.__name__} '
-                        'parent class)')
+                        f'duplicate test {name}.{test_name} (also defined in '
+                        f'{base.__name__} parent class)')
 
         return super().__new__(mcls, name, bases, dict(dct))