diff options
author | Andy McCurdy <andy@andymccurdy.com> | 2021-06-30 16:12:44 -0700 |
---|---|---|
committer | Andy McCurdy <andy@andymccurdy.com> | 2021-06-30 16:12:44 -0700 |
commit | b25cc4ea905c0f01621826b3a7821970fdb313b8 (patch) | |
tree | 9a4680472c3659ad5902ce2ce9f260fe2d1d5b4b | |
parent | ed8c2df14abf166cdb7e1a8bc80c675cf684eeb0 (diff) | |
download | redis-py-b25cc4ea905c0f01621826b3a7821970fdb313b8.tar.gz |
daemonize the thread to see if the tests will continue
-rw-r--r-- | tests/test_pubsub.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/tests/test_pubsub.py b/tests/test_pubsub.py index abeaecb..17a1621 100644 --- a/tests/test_pubsub.py +++ b/tests/test_pubsub.py @@ -1,14 +1,12 @@ -import pytest import threading import time - from unittest import mock +import pytest import redis from redis.exceptions import ConnectionError -from .conftest import _get_client -from .conftest import skip_if_server_version_lt +from .conftest import _get_client, skip_if_server_version_lt def wait_for_message(pubsub, timeout=0.1, ignore_subscribe_messages=False): @@ -561,6 +559,7 @@ class TestPubSubWorkerThread: with mock.patch.object(p, 'get_message', side_effect=Exception('error')): pubsub_thread = p.run_in_thread( + daemon=True, exception_handler=exception_handler ) |