[pre-commit.ci lite] apply automatic fixes

Author: pre-commit-ci-lite[bot]

src/pytest_run_parallel/plugin.py

@@ -107,7 +107,7 @@ def __init__(self, config):
             unsafe_fixtures[item] = False
 
         if self.mark_warnings_as_unsafe:
-            unsafe_fixtures['recwarn'] = False
+            unsafe_fixtures["recwarn"] = False
 
         self.unsafe_fixtures = {uf[0] for uf in unsafe_fixtures.items() if not uf[1]}
 
@@ -144,8 +144,11 @@ def _is_thread_unsafe(self, item):
             return True, f"uses thread-unsafe fixture(s): {used_unsafe_fixtures}"
 
         return identify_thread_unsafe_nodes(
-            item.obj, self.skipped_functions, self.mark_warnings_as_unsafe,
-            self.mark_ctypes_as_unsafe)
+            item.obj,
+            self.skipped_functions,
+            self.mark_warnings_as_unsafe,
+            self.mark_ctypes_as_unsafe,
+        )
 
     @pytest.hookimpl(trylast=True)
     def pytest_itemcollected(self, item):

src/pytest_run_parallel/thread_unsafe_detection.py

@@ -15,13 +15,14 @@
         def is_hypothesis_test(fn):
             return False
 
-WARNINGS_IS_THREADSAFE = (
-    getattr(sys.flags, "context_aware_warnings", 0) and
-    getattr(sys.flags, "thread_inherit_context", 0)
+
+WARNINGS_IS_THREADSAFE = getattr(sys.flags, "context_aware_warnings", 0) and getattr(
+    sys.flags, "thread_inherit_context", 0
 )
 
 CTYPES_IS_THREADSAFE = sys.version_info > (3, 13)
 
+
 def construct_base_blocklist(unsafe_warnings, unsafe_ctypes):
     safe_warnings = not unsafe_warnings and WARNINGS_IS_THREADSAFE
     safe_ctypes = not unsafe_ctypes and CTYPES_IS_THREADSAFE
@@ -37,7 +38,6 @@ def construct_base_blocklist(unsafe_warnings, unsafe_ctypes):
     }
 
 
-
 THREAD_UNSAFE_FIXTURES = {
     "capsys": False,
     "monkeypatch": False,
@@ -136,8 +136,11 @@ def _get_child_fn(mod, node):
             if child_fn is not None and callable(child_fn):
                 self.thread_unsafe, self.thread_unsafe_reason = (
                     identify_thread_unsafe_nodes(
-                        child_fn, self.skip_set, self.unsafe_warnings,
-                        self.unsafe_ctypes, self.level + 1
+                        child_fn,
+                        self.skip_set,
+                        self.unsafe_warnings,
+                        self.unsafe_ctypes,
+                        self.level + 1,
                     )
                 )
 
@@ -184,8 +187,11 @@ def _recursive_analyze_name(self, node):
             if callable(child_fn):
                 self.thread_unsafe, self.thread_unsafe_reason = (
                     identify_thread_unsafe_nodes(
-                        child_fn, self.skip_set, self.unsafe_warnings,
-                        self.unsafe_ctypes, self.level + 1
+                        child_fn,
+                        self.skip_set,
+                        self.unsafe_warnings,
+                        self.unsafe_ctypes,
+                        self.level + 1,
                     )
                 )
 
@@ -228,8 +234,9 @@ def visit(self, node):
         return super().visit(node)
 
 
-def _identify_thread_unsafe_nodes(fn, skip_set, unsafe_warnings, unsafe_ctypes,
-                                  level=0):
+def _identify_thread_unsafe_nodes(
+    fn, skip_set, unsafe_warnings, unsafe_ctypes, level=0
+):
     if is_hypothesis_test(fn):
         return True, "uses hypothesis"
 
@@ -243,20 +250,22 @@ def _identify_thread_unsafe_nodes(fn, skip_set, unsafe_warnings, unsafe_ctypes,
     except Exception:
         return False, None
 
-    visitor = ThreadUnsafeNodeVisitor(fn, skip_set, unsafe_warnings,
-                                      unsafe_ctypes, level=level)
+    visitor = ThreadUnsafeNodeVisitor(
+        fn, skip_set, unsafe_warnings, unsafe_ctypes, level=level
+    )
     visitor.visit(tree)
     return visitor.thread_unsafe, visitor.thread_unsafe_reason
 
 
 cached_thread_unsafe_identify = functools.lru_cache(_identify_thread_unsafe_nodes)
 
 
-def identify_thread_unsafe_nodes(fn, skip_set, unsafe_warnings, unsafe_ctypes,
-                                 level=0):
+def identify_thread_unsafe_nodes(fn, skip_set, unsafe_warnings, unsafe_ctypes, level=0):
     try:
         return cached_thread_unsafe_identify(
-            fn, skip_set, unsafe_warnings, unsafe_ctypes, level=level)
+            fn, skip_set, unsafe_warnings, unsafe_ctypes, level=level
+        )
     except TypeError:
         return _identify_thread_unsafe_nodes(
-            fn, skip_set, unsafe_warnings, unsafe_ctypes, level=level)
+            fn, skip_set, unsafe_warnings, unsafe_ctypes, level=level
+        )

tests/test_thread_unsafe_detection.py

@@ -115,9 +115,10 @@ def test_single_thread_warns_4(num_parallel_threads):
         ]
     )
 
-    if not (getattr(sys.flags, "context_aware_warnings", 0) or
-            getattr(sys.flags, "thread_inherit_context", 0)):
-
+    if not (
+        getattr(sys.flags, "context_aware_warnings", 0)
+        or getattr(sys.flags, "thread_inherit_context", 0)
+    ):
         # check that skipping works too
         result = pytester.runpytest(
             "--parallel-threads=10", "--skip-thread-unsafe=True", "-v"
@@ -132,6 +133,7 @@ def test_single_thread_warns_4(num_parallel_threads):
             ]
         )
 
+
 def test_warns_detection_config_option(pytester):
     # create a temporary pytest test module
     pytester.makepyfile("""
@@ -168,7 +170,9 @@ def test_single_thread_warns_4(num_parallel_threads):
     """)
 
     # run pytest with the following cmd args
-    result = pytester.runpytest("--parallel-threads=10", "-v", "--mark-warnings-as-unsafe")
+    result = pytester.runpytest(
+        "--parallel-threads=10", "-v", "--mark-warnings-as-unsafe"
+    )
 
     # fnmatch_lines does an assertion internally
     result.stdout.fnmatch_lines(
@@ -182,8 +186,10 @@ def test_single_thread_warns_4(num_parallel_threads):
 
     # check that skipping works too
     result = pytester.runpytest(
-        "--parallel-threads=10", "--skip-thread-unsafe=True", "-v",
-        "--mark-warnings-as-unsafe"
+        "--parallel-threads=10",
+        "--skip-thread-unsafe=True",
+        "-v",
+        "--mark-warnings-as-unsafe",
     )
 
     result.stdout.fnmatch_lines(
@@ -196,7 +202,6 @@ def test_single_thread_warns_4(num_parallel_threads):
     )
 
 
-
 def test_thread_unsafe_fixtures(pytester):
     # create a temporary pytest test module
     pytester.makepyfile("""
@@ -563,6 +568,7 @@ def test_thread_unsafe_ctypes(num_parallel_threads):
         ]
     )
 
+
 def test_thread_unsafe_ctypes_config_option(pytester):
     pytester.makepyfile("""
     import ctypes.util
@@ -574,13 +580,15 @@ def test_thread_unsafe_ctypes(num_parallel_threads):
     """)
 
     result = pytester.runpytest(
-        "--parallel-threads=10", "-v", "--mark-ctypes-as-unsafe")
+        "--parallel-threads=10", "-v", "--mark-ctypes-as-unsafe"
+    )
     result.stdout.fnmatch_lines(
         [
             "*::test_thread_unsafe_ctypes PASSED*",
         ]
     )
 
+
 def test_thread_unsafe_ctypes_import_from(pytester):
     pytester.makepyfile("""
     import sys
@@ -621,7 +629,9 @@ def test_thread_unsafe_not_using_ctypes(num_parallel_threads):
         assert num_parallel_threads == 10
     """)
 
-    result = pytester.runpytest("--parallel-threads=10", "-v", "--mark-ctypes-as-unsafe")
+    result = pytester.runpytest(
+        "--parallel-threads=10", "-v", "--mark-ctypes-as-unsafe"
+    )
     result.stdout.fnmatch_lines(
         [
             "*::test_thread_unsafe_ctypes PASSED*",