pypy skipif

Author: chayim

tests/test_pubsub.py

@@ -1,6 +1,7 @@
 import threading
 import time
 from unittest import mock
+import platform
 
 import pytest
 import redis
@@ -547,6 +548,8 @@ def test_get_message_with_timeout_returns_none(self, r):
 
 
 class TestPubSubWorkerThread:
+
+    @pytest.mark.skipif(platform.python_implementation() == 'PyPy', reason="Pypy threading issue")
     def test_pubsub_worker_thread_exception_handler(self, r):
         event = threading.Event()