Assert GIL has been enabled

Author: lysnikolaou

src/pytest_run_parallel/plugin.py

@@ -121,6 +121,14 @@ def __init__(self, config):
         self.thread_unsafe = {}
         self.run_in_parallel = {}
 
+        self.gil_initially_disabled = self._is_gil_enabled()
+
+    @staticmethod
+    def _is_gil_enabled():
+        if hasattr(sys, "_is_gil_enabled"):
+            return sys._is_gil_enabled()
+        return True
+
     def skipped_or_not_parallel(self, *, plural):
         if plural:
             skipped = "were skipped"
@@ -286,6 +294,7 @@ def pytest_warning_recorded(
         if mo is None or self.ignore_gil_enabled:
             return
 
+        assert self.gil_initially_disabled and self._is_gil_enabled()
         if when == "collect":
             stage = "collection"
         elif when == "runtest":

tests/test_run_parallel.py

@@ -646,6 +646,16 @@ def test_uses_hypothesis(a, num_parallel_threads):
 
 def test_fail_warning_gil_enabled_during_execution(pytester):
     test_name = "test_fail_warning_gil_enabled_during_execution"
+    pytester.makeconftest("""
+    import sys
+    import pytest
+
+    @pytest.hookimpl
+    def pytest_sessionstart(session):
+        if not hasattr(sys, "_is_gil_enabled"):
+            sys._is_gil_enabled = lambda: True
+    """)
+
     pytester.makepyfile(f"""
     import warnings
 
@@ -666,6 +676,16 @@ def {test_name}():
 
 def test_fail_warning_gil_enabled_during_collection(pytester):
     test_name = "test_fail_warning_gil_enabled_during_collection"
+    pytester.makeconftest("""
+    import sys
+    import pytest
+
+    @pytest.hookimpl
+    def pytest_sessionstart(session):
+        if not hasattr(sys, "_is_gil_enabled"):
+            sys._is_gil_enabled = lambda: True
+    """)
+
     pytester.makepyfile(f"""
     import warnings
     warnings.warn(