Test Python thread safety with pytest-run-parallel

Author: cclauss

.github/workflows/integration.yaml

@@ -25,27 +25,27 @@ jobs:
     strategy:
       max-parallel: 15
       matrix:
-        python-version: ['3.8', '3.9', '3.10', '3.11', '3.12', '3.13', '3.14', '3.14t', 'pypy-3.8', 'pypy-3.9', 'pypy-3.10', 'pypy-3.11']
+        python-version: ['3.9', '3.10', '3.11', '3.12', '3.13', '3.14', '3.14t', 'pypy-3.9', 'pypy-3.10', 'pypy-3.11']
         os: ['ubuntu-latest', 'windows-latest', 'macos-latest']
       fail-fast: false
     env:
       ACTIONS_ALLOW_UNSECURE_COMMANDS: true
     name: Python ${{ matrix.python-version }} ${{matrix.os}}
     steps:
-      - uses: actions/checkout@v4
+      - uses: actions/checkout@v5
         with:
           submodules: recursive
-      - uses: actions/setup-python@v5
+      - uses: actions/setup-python@v6
         with:
           python-version: ${{ matrix.python-version }}
           cache: 'pip'
           cache-dependency-path: dev_requirements.txt
       - name: run tests
         run: |
-          pip install -U pip setuptools wheel
+          pip install --upgrade pip setuptools wheel
           pip install -r dev_requirements.txt
           python setup.py build_ext --inplace
-          python -m pytest
+          python -m pytest --iterations=8 --parallel-threads=auto
       - name: build and install the wheel
         run: |
           python setup.py bdist_wheel

dev_requirements.txt

@@ -2,6 +2,7 @@ black==24.3.0
 flake8==4.0.1
 isort==5.10.1
 pytest>=7.0.0
+pytest-run-parallel>=0.7.1
 setuptools
 vulture>=2.3.0
 wheel>=0.30.0

tests/test_reader.py

@@ -174,6 +174,8 @@ def test_dict(reader):
     assert {b"radius": 4.5, b"diameter": 9} == reader.gets()
 
 
+@pytest.mark.iterations(1)
+@pytest.mark.thread_unsafe
 def test_set_with_nested_dict(reader):
     reader.feed(b"~2\r\n+tangerine\r\n%1\r\n+a\r\n:1\r\n")
     if reader.convertSetsToLists:
@@ -196,6 +198,8 @@ def test_map_inside_list(reader):
     assert [{b"a": 1}] == reader.gets()
 
 
+@pytest.mark.iterations(1)
+@pytest.mark.thread_unsafe
 def test_map_inside_set(reader):
     reader.feed(b"~1\r\n%1\r\n+a\r\n:1\r\n")
     if reader.convertSetsToLists:
@@ -206,6 +210,8 @@ def test_map_inside_set(reader):
             reader.gets()
 
 
+@pytest.mark.iterations(1)
+@pytest.mark.thread_unsafe
 def test_set_as_map_key(reader):
     reader.feed(b"%1\r\n~1\r\n:1\r\n:2\r\n")
     with pytest.raises(TypeError):
@@ -388,6 +394,8 @@ def test_feed_bytearray(reader):
     assert b"ok" == reader.gets()
 
 
+@pytest.mark.iterations(1)
+@pytest.mark.thread_unsafe
 def test_maxbuf(reader):
     defaultmaxbuf = reader.getmaxbuf()
     reader.setmaxbuf(0)
@@ -400,6 +408,8 @@ def test_maxbuf(reader):
         reader.setmaxbuf(-4)
 
 
+@pytest.mark.iterations(1)
+@pytest.mark.thread_unsafe
 def test_len(reader):
     assert reader.len() == 0
     data = b"+ok\r\n"
@@ -416,6 +426,8 @@ def test_len(reader):
     assert reader.len() == 5
 
 
+@pytest.mark.iterations(1)
+@pytest.mark.thread_unsafe
 def test_reader_has_data(reader):
     assert reader.has_data() is False
     data = b"+ok\r\n"