Skip to content

Commit 935b594

Browse files
authored
chore: remove the global thread tear down in the streaming tests (#377)
1 parent 58b3e8d commit 935b594

File tree

1 file changed

+0
-17
lines changed

1 file changed

+0
-17
lines changed

tests/unit_tests/test_client_streaming.py

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
"""
44

55
import json
6-
import threading
76
import time
87
from io import BytesIO
98

@@ -14,27 +13,11 @@
1413
from UnleashClient.cache import FileCache
1514

1615

17-
def cleanup_threads():
18-
"""Wait for all background threads to finish."""
19-
for thread in threading.enumerate():
20-
if thread != threading.current_thread() and thread.is_alive():
21-
if (
22-
hasattr(thread, "_stop")
23-
or "unleash" in thread.name.lower()
24-
or "scheduler" in thread.name.lower()
25-
):
26-
try:
27-
thread.join(timeout=2.0)
28-
except Exception:
29-
pass
30-
31-
3216
@pytest.fixture(autouse=True)
3317
def reset_instances(tmp_path):
3418
"""Reset instances before each test and ensure clean cache."""
3519
INSTANCES._reset()
3620
yield
37-
cleanup_threads()
3821

3922

4023
@pytest.fixture

0 commit comments

Comments
 (0)